[irods#28] Update python tests

SwooshyCueb · Nov 7, 2022 · 90e1778 · 90e1778
1 parent 4069fc9
commit 90e1778
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/packaging/message_broker_consumer.py b/packaging/message_broker_consumer.py
@@ -40,7 +40,7 @@ def on_message(self, event):
                 #print(message)
                 self.pid_dictionary[pid].append(message)
 
-            elif action == 'END' and pid in self.pid_dictionary:
+            elif action == 'STOP' and pid in self.pid_dictionary:
                 #print(message)
                 #print(pid)
                 self.pid_dictionary[pid].append(message)

diff --git a/packaging/queue_listener.py b/packaging/queue_listener.py
@@ -17,7 +17,7 @@ def __init__(self, pid_queue, result_queue, url, queue_name):
 
     def run(self):
 
-        timeout = 5
+        timeout = 3
         num_workers = 5
         for _ in range(num_workers):
             worker = MessageWorker(self.pid_queue, self.result_queue)