Skip to content

Commit 177dbd9

Browse files
committed
Stack contexts I
1 parent a7d0979 commit 177dbd9

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

temporalio/worker/_workflow_instance.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -210,8 +210,8 @@ def __init__(self, det: WorkflowInstanceDetails) -> None:
210210
self._defn = det.defn
211211
self._workflow_input: Optional[ExecuteWorkflowInput] = None
212212
self._info = det.info
213-
self._context_free_payload_converter = det.payload_converter_class()
214-
self._context_free_failure_converter = det.failure_converter_class()
213+
self._payload_converter = det.payload_converter_class()
214+
self._failure_converter = det.failure_converter_class()
215215
self._payload_converter, self._failure_converter = self._converters(
216216
temporalio.converter.WorkflowSerializationContext(
217217
namespace=det.info.namespace,
@@ -2063,8 +2063,8 @@ def _converters(
20632063
temporalio.converter.FailureConverter,
20642064
]:
20652065
"""Construct workflow payload and failure converters with the given context."""
2066-
payload_converter = self._context_free_payload_converter
2067-
failure_converter = self._context_free_failure_converter
2066+
payload_converter = self._payload_converter
2067+
failure_converter = self._failure_converter
20682068
if context:
20692069
if isinstance(
20702070
payload_converter, temporalio.converter.WithSerializationContext

0 commit comments

Comments
 (0)