Merge pull request #51 from amplab/timing

Increase waiting time when the cluster gets started
This commit is contained in:
Robert Nishihara
2016-04-22 11:43:17 -07:00
+1 -1
View File
@@ -98,4 +98,4 @@ def start_cluster(driver_worker=None, num_workers=0, worker_path=None):
orchpy.connect(scheduler_address, objstore_address, address(IP_ADDRESS, new_worker_port()))
for _ in range(num_workers):
start_worker(worker_path, scheduler_address, objstore_address, address(IP_ADDRESS, new_worker_port()))
time.sleep(0.3)
time.sleep(0.5)