Update receiver_mpi.py

Removed time.sleep
rkube · Jan 15, 2020 · c1d44dc · c1d44dc
1 parent cf97b9c
commit c1d44dc
Showing 1 changed file with 0 additions and 2 deletions.
diff --git 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()