Skip to content

Commit d7f2e9f

Browse files
committed
Refactor
1 parent b43b980 commit d7f2e9f

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

temporalio/workflow.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1237,16 +1237,19 @@ def process(
12371237
or self.full_workflow_info_on_extra
12381238
):
12391239
extra = {}
1240+
msg_extra = {}
12401241
runtime = _Runtime.maybe_current()
12411242
if runtime:
12421243
if self.workflow_info_on_message:
1243-
msg = f"{msg} ({runtime.logger_details})"
1244+
msg_extra.update(runtime.logger_details)
12441245
if self.workflow_info_on_extra:
12451246
extra["temporal_workflow"] = runtime.logger_details
12461247
if self.full_workflow_info_on_extra:
12471248
extra["workflow_info"] = runtime.workflow_info()
12481249

12491250
kwargs["extra"] = {**extra, **(kwargs.get("extra") or {})}
1251+
if msg_extra:
1252+
msg = f"{msg} ({msg_extra})"
12501253
return (msg, kwargs)
12511254

12521255
def isEnabledFor(self, level: int) -> bool:

0 commit comments

Comments
 (0)