Skip to content

Commit 3831f44

Browse files
committed
sleep for some time before signalling shutdown
1 parent ce582e0 commit 3831f44

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

rpc/launch_tpch_queries.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -241,6 +241,9 @@ def main():
241241
for p in ps:
242242
p.wait()
243243

244+
# Wait for some time before sending the shutdown signal
245+
time.sleep(20)
246+
244247
channel = grpc.insecure_channel("localhost:50051")
245248
stub = erdos_scheduler_pb2_grpc.SchedulerServiceStub(channel)
246249
response = stub.Shutdown(erdos_scheduler_pb2.Empty())

0 commit comments

Comments
 (0)