|
@@ -42,8 +42,8 @@ class AlarmPlanDispatcher:
|
|
|
plan = self.task_queue.get(timeout=1)
|
|
plan = self.task_queue.get(timeout=1)
|
|
|
if plan is None:
|
|
if plan is None:
|
|
|
break
|
|
break
|
|
|
- if plan.handle_func:
|
|
|
|
|
- plan.handle_func(plan)
|
|
|
|
|
|
|
+ if plan.handle_func_:
|
|
|
|
|
+ plan.handle_func_(plan)
|
|
|
else:
|
|
else:
|
|
|
LOGINFO(f"[Dispatcher] Plan {plan.plan_uuid_} has no handler")
|
|
LOGINFO(f"[Dispatcher] Plan {plan.plan_uuid_} has no handler")
|
|
|
except queue.Empty:
|
|
except queue.Empty:
|
