From bb3282f4190f7e75350b044b3661fed32540170d Mon Sep 17 00:00:00 2001 From: lwolczynski Date: Fri, 6 Dec 2024 13:19:15 -0600 Subject: [PATCH] IWF-397: Add channel sizes data # Conflicts: # iwf/communication.py # iwf/tests/test_signal.py # iwf/worker_service.py --- iwf/tests/test_rpc.py | 2 +- iwf/tests/worker_server.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/iwf/tests/test_rpc.py b/iwf/tests/test_rpc.py index a347b1b..67b8289 100644 --- 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 index 3592dc5..74e51a0 100644 --- 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()