From c1d44dc77729b551b5c9528e284d561586011ae2 Mon Sep 17 00:00:00 2001 From: Jong Choi Date: Wed, 15 Jan 2020 17:16:44 -0500 Subject: [PATCH] Update receiver_mpi.py Removed time.sleep --- receiver_mpi.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/receiver_mpi.py b/receiver_mpi.py index 268033b..47777ec 100644 --- a/receiver_mpi.py +++ b/receiver_mpi.py @@ -62,7 +62,6 @@ def perform_analysis(channel_data, step): # Store result in database # backend.store(my_analysis, analysis_result) - time.sleep(10) print(">>> ({0:d}) Worker: done with analysis step={1:d} ({2:f} secs)".format(rank, step, t1-t0)) # Function for a helper thead (dispatcher). @@ -121,7 +120,6 @@ def dispatch(): # Save data in a queue then go back to work # Dispatcher (a helper thread) will fetch asynchronously. dq.put((channel_data, currentStep)) - time.sleep(1) ## Clean up dq.join()