Merge cluster to master #3
|
@ -65,8 +65,8 @@ def need_to_wait(backend_url: str):
|
|||
active_workers = redis.get(f'active_gen_workers:{backend_url}', 0, dtype=int)
|
||||
concurrent_gens = cluster_config.get_backend(backend_url).get('concurrent_gens', 1)
|
||||
s = time.time()
|
||||
print(active_workers >= concurrent_gens, active_workers, concurrent_gens)
|
||||
while active_workers >= concurrent_gens:
|
||||
print('worker waiting')
|
||||
time.sleep(0.01)
|
||||
e = time.time()
|
||||
if e - s > 0.5:
|
||||
|
|
Reference in New Issue