Skip to content

Commit 1e9b241

Browse files
committed
Use ActivitySerializationContext when describing a Standalone Activity
1 parent bda846f commit 1e9b241

1 file changed

Lines changed: 10 additions & 2 deletions

File tree

temporalio/client/_impl.py

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -693,14 +693,22 @@ async def describe_activity(
693693
metadata=input.rpc_metadata,
694694
timeout=input.rpc_timeout,
695695
)
696+
activity_type = (
697+
resp.info.activity_type.name if resp.info.HasField("activity_type") else ""
698+
)
696699
return await ActivityExecutionDescription._from_execution_info(
697700
info=resp.info,
698701
long_poll_token=resp.long_poll_token or None,
699702
namespace=self._client.namespace,
700703
data_converter=self._client.data_converter.with_context(
701-
WorkflowSerializationContext(
704+
ActivitySerializationContext(
702705
namespace=self._client.namespace,
703-
workflow_id=input.activity_id, # Using activity_id as workflow_id for activities not started by a workflow
706+
activity_id=resp.info.activity_id,
707+
activity_task_queue=resp.info.task_queue,
708+
activity_type=activity_type,
709+
workflow_id=None,
710+
workflow_type=None,
711+
is_local=False,
704712
)
705713
),
706714
)

0 commit comments

Comments
 (0)