fix queue bug

Signed-off-by: wzh <[email protected]>
pyisong · May 20, 2020 · 333df38 · 333df38
1 parent b00fc16
commit 333df38
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/fate_flow/manager/queue_manager.py b/fate_flow/manager/queue_manager.py
@@ -175,7 +175,7 @@ def update_event(self, job_id='', item=None, status=None, operating=None):
             event = events[0]
             event.f_is_waiting = status
             if operating == 'put':
-                if event.f_frequency <= RE_ENTRY_QUEUE_MAX and status==3:
+                if event.f_frequency <= RE_ENTRY_QUEUE_MAX:
                     event.f_frequency += 1
                 else:
                     event.f_is_waiting = 4