Skip to content

Commit 5fcd282

Browse files
committed
Wire activity context
1 parent 2c08f96 commit 5fcd282

File tree

1 file changed

+13
-0
lines changed

1 file changed

+13
-0
lines changed

temporalio/worker/_workflow_instance.py

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -758,9 +758,22 @@ def _apply_resolve_activity(
758758
ret: Optional[Any] = None
759759
if job.result.completed.HasField("result"):
760760
ret_types = [handle._input.ret_type] if handle._input.ret_type else None
761+
context = temporalio.converter.ActivitySerializationContext(
762+
namespace=self._info.namespace,
763+
workflow_id=self._info.workflow_id,
764+
workflow_type=self._info.workflow_type,
765+
activity_type=handle._input.activity,
766+
activity_task_queue=(
767+
handle._input.task_queue or ""
768+
if isinstance(handle._input, StartActivityInput)
769+
else ""
770+
),
771+
is_local=isinstance(handle._input, StartLocalActivityInput),
772+
)
761773
ret_vals = self._convert_payloads(
762774
[job.result.completed.result],
763775
ret_types,
776+
context,
764777
)
765778
ret = ret_vals[0]
766779
handle._resolve_success(ret)

0 commit comments

Comments
 (0)