diff --git a/apps/em/tasks.py b/apps/em/tasks.py
index 076cafd9..f1bbf308 100644
--- a/apps/em/tasks.py
+++ b/apps/em/tasks.py
@@ -28,7 +28,7 @@ def check_mgroup_running():
     """监测工段是否运行
     """
     # 没有设备的工段直接干停
-    Mgroup.objects.filter(equip_mgroup__indicate_mgroup_running__isnull=True).distinct().update(is_running=False)
+    Mgroup.objects.filter(equip_mgroup__isnull=True, is_running=True).distinct().update(is_running=False)
     equips = Equipment.objects.filter(indicate_mgroup_running__isnull=False, mgroup__isnull=False)
     for equip in equips:
         rs = get_eq_rs(equip.id)