job quantity constraint add sleep 1s

Signed-off-by: wzh <[email protected]>
pyisong · May 20, 2020 · f540baf · f540baf
1 parent 81aecc6
commit f540baf
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/fate_flow/utils/job_controller_utils.py b/fate_flow/utils/job_controller_utils.py
@@ -1,3 +1,4 @@
+import time
 from threading import Lock
 
 from arch.standalone import WorkMode
@@ -10,6 +11,7 @@
 def job_quantity_constraint(job_id, role, party_id, job_info):
     lock = Lock()
     with lock:
+        time.sleep(1)
         if RuntimeConfig.WORK_MODE == WorkMode.CLUSTER:
             if role == LIMIT_ROLE:
                 running_jobs = job_utils.query_job(status='running', role=role)