diff --git a/apps/node_man/migrations/0084_alter_nodeman_jsonfield_default_value.py b/apps/node_man/migrations/0085_alter_nodeman_jsonfield_default_value.py similarity index 97% rename from apps/node_man/migrations/0084_alter_nodeman_jsonfield_default_value.py rename to apps/node_man/migrations/0085_alter_nodeman_jsonfield_default_value.py index e271fc718..1bdf2e312 100644 --- a/apps/node_man/migrations/0084_alter_nodeman_jsonfield_default_value.py +++ b/apps/node_man/migrations/0085_alter_nodeman_jsonfield_default_value.py @@ -6,7 +6,7 @@ class Migration(migrations.Migration): dependencies = [ - ("node_man", "0083_subscription_operate_info"), + ("node_man", "0084_update_isp_and_accesspoint_regionid_cityid"), ] operations = [ diff --git a/apps/node_man/periodic_tasks/sync_all_isp_to_cmdb.py b/apps/node_man/periodic_tasks/sync_all_isp_to_cmdb.py index 42f7674a6..585b22b57 100644 --- a/apps/node_man/periodic_tasks/sync_all_isp_to_cmdb.py +++ b/apps/node_man/periodic_tasks/sync_all_isp_to_cmdb.py @@ -11,7 +11,7 @@ import time from typing import Any, Dict, List -from celery.task import periodic_task +from celery import current_app from apps.component.esbclient import client_v2 from apps.exceptions import ComponentCallError @@ -47,7 +47,7 @@ def sync_all_isp_to_cmdb(task_id): logger.info(f"{task_id} | Sync cloud isp info task complete.") -@periodic_task( +@current_app.task( queue="default", options={"queue": "default"}, run_every=constants.SYNC_ISP_TO_CMDB_INTERVAL,