diff --git a/temporalio/activity.py b/temporalio/activity.py index c4e5941bb..3332823fd 100644 --- a/temporalio/activity.py +++ b/temporalio/activity.py @@ -363,7 +363,6 @@ def process( self, msg: Any, kwargs: MutableMapping[str, Any] ) -> Tuple[Any, MutableMapping[str, Any]]: """Override to add activity details.""" - msg, kwargs = super().process(msg, kwargs) if self.activity_info_on_message or self.activity_info_on_extra: context = _current_context.get(None) if context: diff --git a/temporalio/workflow.py b/temporalio/workflow.py index 9184ebf15..a7cd8f07b 100644 --- a/temporalio/workflow.py +++ b/temporalio/workflow.py @@ -831,7 +831,6 @@ def process( self, msg: Any, kwargs: MutableMapping[str, Any] ) -> Tuple[Any, MutableMapping[str, Any]]: """Override to add workflow details.""" - msg, kwargs = super().process(msg, kwargs) if self.workflow_info_on_message or self.workflow_info_on_extra: runtime = _Runtime.maybe_current() if runtime: