Update proxyqueue.py

globus-labs · Nov 29, 2024 · 7743299 · 7743299
1 parent 05a649b
commit 7743299
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/mofa/proxyqueue.py b/mofa/proxyqueue.py
@@ -244,6 +244,10 @@ def _get_result(self, topic: str, timeout: int = None) -> str:
     #     print(queues._send_result("_send_result message111", "generation"))
     #     print(queues._send_result("_send_result message222", "generation"))
 
+    # for future impl for ColmenaQueues:
+    # it's very importantant to ensure serilization works
+    # otherwise it would cause silent errors in MOFA,
+    # causing future operation to fail
     # queues_dumped = pickle.dumps(queues)
     # queues_loaded = pickle.loads(queues_dumped)
     # for i in range(10):