diff --git a/api/tasks/process_tenant_plugin_autoupgrade_check_task.py b/api/tasks/process_tenant_plugin_autoupgrade_check_task.py index 37bdab527d..825527f22b 100644 --- a/api/tasks/process_tenant_plugin_autoupgrade_check_task.py +++ b/api/tasks/process_tenant_plugin_autoupgrade_check_task.py @@ -119,6 +119,7 @@ def marketplace_batch_fetch_plugin_manifests( return result + def fetch_global_plugin_manifest(): url = str(marketplace_api_url / "api/v1/dist/plugins/manifest.json") response = httpx.get(url, headers={"X-Dify-Version": dify_config.project.version}, timeout=30) @@ -132,6 +133,7 @@ def fetch_global_plugin_manifest(): value=plugin_snapshot.model_dump_json(), ) + @shared_task(queue="plugin") def process_tenant_plugin_autoupgrade_check_task( tenant_id: str,