IWF-397: Add channel sizes data

# Conflicts: # iwf/communication.py # iwf/tests/test_signal.py # iwf/worker_service.py
indeedeng · Jan 7, 2025 · bb3282f · bb3282f
1 parent a85eb32
commit bb3282f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/iwf/tests/test_rpc.py b/iwf/tests/test_rpc.py
@@ -121,7 +121,7 @@ def test_simple_rpc(self):
 
     def test_complicated_rpc(self):
         wf_id = f"{inspect.currentframe().f_code.co_name}-{time.time_ns()}"
-        self.client.start_workflow(RPCWorkflow, wf_id, 10)
+        self.client.start_workflow(RPCWorkflow, wf_id, 100)
         self.client.invoke_rpc(wf_id, RPCWorkflow.test_rpc_persistence_write, 100)
         res = self.client.invoke_rpc(wf_id, RPCWorkflow.test_rpc_persistence_read)
         assert res == 100

diff --git a/iwf/tests/worker_server.py b/iwf/tests/worker_server.py
@@ -14,7 +14,7 @@
 
 # NOTE: set this to true when debugging(using breakpoints)
 # so that it keep the thread running so that we can see the error in history
-debug_mode: bool = False
+debug_mode: bool = True
 
 registry = Registry()