From 1e9b2419a8126b19e1ae0fd833725b109ba7f77e Mon Sep 17 00:00:00 2001 From: Alex Mazzeo Date: Thu, 4 Jun 2026 15:37:51 -0700 Subject: [PATCH 1/2] Use ActivitySerializationContext when describing a Standalone Activity --- temporalio/client/_impl.py | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/temporalio/client/_impl.py b/temporalio/client/_impl.py index 0f3667b19..2a9238691 100644 --- a/temporalio/client/_impl.py +++ b/temporalio/client/_impl.py @@ -693,14 +693,22 @@ async def describe_activity( metadata=input.rpc_metadata, timeout=input.rpc_timeout, ) + activity_type = ( + resp.info.activity_type.name if resp.info.HasField("activity_type") else "" + ) return await ActivityExecutionDescription._from_execution_info( info=resp.info, long_poll_token=resp.long_poll_token or None, namespace=self._client.namespace, data_converter=self._client.data_converter.with_context( - WorkflowSerializationContext( + ActivitySerializationContext( namespace=self._client.namespace, - workflow_id=input.activity_id, # Using activity_id as workflow_id for activities not started by a workflow + activity_id=resp.info.activity_id, + activity_task_queue=resp.info.task_queue, + activity_type=activity_type, + workflow_id=None, + workflow_type=None, + is_local=False, ) ), ) From ad437ee2a74876b5caaed32fd27459d0ae47f89c Mon Sep 17 00:00:00 2001 From: Alex Mazzeo Date: Fri, 5 Jun 2026 09:24:38 -0700 Subject: [PATCH 2/2] remove unnecessary check --- temporalio/client/_impl.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/temporalio/client/_impl.py b/temporalio/client/_impl.py index 2a9238691..e62f0b4a2 100644 --- a/temporalio/client/_impl.py +++ b/temporalio/client/_impl.py @@ -693,9 +693,6 @@ async def describe_activity( metadata=input.rpc_metadata, timeout=input.rpc_timeout, ) - activity_type = ( - resp.info.activity_type.name if resp.info.HasField("activity_type") else "" - ) return await ActivityExecutionDescription._from_execution_info( info=resp.info, long_poll_token=resp.long_poll_token or None, @@ -705,7 +702,7 @@ async def describe_activity( namespace=self._client.namespace, activity_id=resp.info.activity_id, activity_task_queue=resp.info.task_queue, - activity_type=activity_type, + activity_type=resp.info.activity_type.name, workflow_id=None, workflow_type=None, is_local=False,