diff --git a/apps/em/services.py b/apps/em/services.py
index c8a7719d..8bcab525 100644
--- a/apps/em/services.py
+++ b/apps/em/services.py
@@ -4,7 +4,6 @@ from apps.mtm.models import Mgroup
 import datetime
 from django.core.cache import cache
 from django.utils.timezone import localtime
-from apps.utils.tasks import ctask_run
 
 def get_eq_rs(equipId: str):
     """获取设备运行状态缓存
@@ -26,7 +25,7 @@ def set_eq_rs(equipId, last_timex: datetime, last_mrs: int):
 
         cache.set(f"equipment_{equipId}", {"running_state": last_mrs, "running_state_timex": last_timex}, timeout=None) # 更新缓存
         if eq_rs_change:
-            ctask_run.delay("apps.em.services.shutdown_or_startup", equipId, last_timex, last_mrs)
+            shutdown_or_startup(equipId, last_timex, last_mrs)
 
 
 def shutdown_or_startup(equipId: str, last_timex: datetime, last_mrs):
diff --git a/apps/enm/services.py b/apps/enm/services.py
index 505c41f1..808c4147 100644
--- a/apps/enm/services.py
+++ b/apps/enm/services.py
@@ -11,7 +11,6 @@ from django.db import connection, transaction
 from datetime import datetime, timedelta
 from apps.utils.decorators import auto_log
 from django.db import IntegrityError
-from apps.utils.tasks import ctask_run
 from .serializers import MpointSerializer
 from apps.enp.models import EnvData
 from apps.em.models import Equipment