fix: em/bug
This commit is contained in:
parent
7517da3e92
commit
9f90d84244
|
@ -42,7 +42,7 @@ def set_eq_rs(equipId, last_timex: datetime, last_mrs: int):
|
|||
update_time = eq_rs_cache.get('update_time', baseTime)
|
||||
cache.set(f"equipment_{equipId}", {"running_state": last_mrs, "running_state_timex": last_timex, "update_time":update_time}, timeout=None) # 更新缓存
|
||||
if eq_rs_change:
|
||||
ctask_run.delay("apps.em.services.shutdown_or_startup", equipId, last_timex, last_mrs, mgroup_sort_trigger)
|
||||
ctask_run.delay("apps.em.services.shutdown_or_startup", equipId, last_timex, last_mrs, '', mgroup_sort_trigger)
|
||||
|
||||
|
||||
def shutdown_or_startup(equipId: str, last_timex: datetime, last_mrs, note: str = "", mgroup_sort_trigger: bool = False):
|
||||
|
|
Loading…
Reference in New Issue