Skip to content

Commit ab7c36e

Browse files
committed
Store data_converter on WorkflowInstanceDetails instead of converter classes
1 parent d725e21 commit ab7c36e

File tree

3 files changed

+9
-8
lines changed

3 files changed

+9
-8
lines changed

temporalio/worker/_workflow.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -565,8 +565,7 @@ def _create_workflow_instance(
565565

566566
# Create instance from details
567567
det = WorkflowInstanceDetails(
568-
payload_converter_class=self._data_converter.payload_converter_class,
569-
failure_converter_class=self._data_converter.failure_converter_class,
568+
data_converter=self._data_converter,
570569
interceptor_classes=self._interceptor_classes,
571570
defn=defn,
572571
info=info,

temporalio/worker/_workflow_instance.py

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -135,8 +135,7 @@ def set_worker_level_failure_exception_types(
135135
class WorkflowInstanceDetails:
136136
"""Immutable details for creating a workflow instance."""
137137

138-
payload_converter_class: Type[temporalio.converter.PayloadConverter]
139-
failure_converter_class: Type[temporalio.converter.FailureConverter]
138+
data_converter: temporalio.converter.DataConverter
140139
interceptor_classes: Sequence[Type[WorkflowInboundInterceptor]]
141140
defn: temporalio.workflow._Definition
142141
info: temporalio.workflow.Info
@@ -210,8 +209,12 @@ def __init__(self, det: WorkflowInstanceDetails) -> None:
210209
self._defn = det.defn
211210
self._workflow_input: Optional[ExecuteWorkflowInput] = None
212211
self._info = det.info
213-
self._context_free_payload_converter = det.payload_converter_class()
214-
self._context_free_failure_converter = det.failure_converter_class()
212+
self._context_free_payload_converter = (
213+
det.data_converter.payload_converter_class()
214+
)
215+
self._context_free_failure_converter = (
216+
det.data_converter.failure_converter_class()
217+
)
215218
self._payload_converter, self._failure_converter = (
216219
self._converters_with_context(
217220
temporalio.converter.WorkflowSerializationContext(

temporalio/worker/workflow_sandbox/_runner.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,8 +77,7 @@ def prepare_workflow(self, defn: temporalio.workflow._Definition) -> None:
7777
# Just create with fake info which validates
7878
self.create_instance(
7979
WorkflowInstanceDetails(
80-
payload_converter_class=temporalio.converter.DataConverter.default.payload_converter_class,
81-
failure_converter_class=temporalio.converter.DataConverter.default.failure_converter_class,
80+
data_converter=temporalio.converter.DataConverter.default,
8281
interceptor_classes=[],
8382
defn=defn,
8483
# Just use fake info during validation

0 commit comments

Comments
 (0)