diff --git a/apps/em/tasks.py b/apps/em/tasks.py
index 34b8b2d7..0587617b 100644
--- a/apps/em/tasks.py
+++ b/apps/em/tasks.py
@@ -27,8 +27,8 @@ def check_equipment_offline(seconds=30):
 def check_mgroup_running():
     """监测工段是否运行
     """
-    # 没有设备的工段直接干停
-    Mgroup.objects.filter(equip_mgroup__isnull=True, is_running=True).distinct().update(is_running=False)
+    # 没有标志设备的工段直接干停
+    Mgroup.objects.filter(is_running=True).exclude(id__in=Equipment.objects.filter(indicate_mgroup_running__isnull=False, mgroup__isnull=False).values_list('mgroup', flat=True)).update(is_running=True)
     # equips = Equipment.objects.filter(indicate_mgroup_running__isnull=False, mgroup__isnull=False)
     # for equip in equips:
     #     rs = get_eq_rs(equip.id)