Skip to content

Commit cc83c07

Browse files
committed
Optimize codec visitor
1 parent 6f9fd18 commit cc83c07

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

temporalio/bridge/worker.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -284,7 +284,8 @@ def __init__(self, f: Callable[[Sequence[Payload]], Awaitable[List[Payload]]]):
284284

285285
async def visit_payload(self, payload: Payload) -> None:
286286
new_payload = (await self._f([payload]))[0]
287-
payload.CopyFrom(new_payload)
287+
if new_payload is not payload:
288+
payload.CopyFrom(new_payload)
288289

289290
async def visit_payloads(self, payloads: MutableSequence[Payload]) -> None:
290291
if len(payloads) == 0:

0 commit comments

Comments
 (0)