From 20e0e22b993095858f2abec8d837cd988bf35a96 Mon Sep 17 00:00:00 2001 From: lwolczynski Date: Fri, 3 Jan 2025 12:24:47 -0600 Subject: [PATCH] IWF-357: Fix --- iwf/worker_service.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/iwf/worker_service.py b/iwf/worker_service.py index 5480962..520ff43 100644 --- a/iwf/worker_service.py +++ b/iwf/worker_service.py @@ -70,7 +70,7 @@ def handle_workflow_worker_rpc( wf_type = request.workflow_type rpc_info = self._registry.get_rpc_infos(wf_type)[request.rpc_name] - internal_channel_types = self._registry.get_internal_channel_types(wf_type) + internal_channel_types = self._registry.get_internal_channel_type_store(wf_type) signal_channel_types = self._registry.get_signal_channel_types(wf_type) data_attributes_types = self._registry.get_data_attribute_types(wf_type) @@ -141,7 +141,7 @@ def handle_workflow_state_wait_until( state = self._registry.get_workflow_state_with_check( wf_type, request.workflow_state_id ) - internal_channel_types = self._registry.get_internal_channel_types(wf_type) + internal_channel_types = self._registry.get_internal_channel_type_store(wf_type) signal_channel_types = self._registry.get_signal_channel_types(wf_type) data_attributes_types = self._registry.get_data_attribute_types(wf_type) @@ -187,7 +187,7 @@ def handle_workflow_state_execute( state = self._registry.get_workflow_state_with_check( wf_type, request.workflow_state_id ) - internal_channel_types = self._registry.get_internal_channel_types(wf_type) + internal_channel_types = self._registry.get_internal_channel_type_store(wf_type) signal_channel_types = self._registry.get_signal_channel_types(wf_type) data_attributes_types = self._registry.get_data_attribute_types(wf_type) context = _from_idl_context(request.context)