Skip to content

Commit 7a823ea

Browse files
committed
Changed null encoding to fix behavior on x86.
1 parent 77ccecc commit 7a823ea

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

temporalio/worker/_workflow_instance.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1113,9 +1113,11 @@ def workflow_upsert_memo(self, updates: Mapping[str, Any]) -> None:
11131113
fields[k].CopyFrom(v)
11141114
mut_raw_memo[k] = v
11151115

1116-
for k in removals:
1117-
fields.get_or_create(k)
1118-
mut_raw_memo.pop(k, None)
1116+
if removals:
1117+
null_payload = self._payload_converter.to_payload(None)
1118+
for k in removals:
1119+
fields[k].CopyFrom(null_payload)
1120+
mut_raw_memo.pop(k, None)
11191121

11201122
# Clearing cached value, will be regenerated on next workflow_memo() call.
11211123
self._untyped_converted_memo = None

0 commit comments

Comments
 (0)