Skip to content

Commit d4812c3

Browse files
committed
RTU: operation_id -> operation_token
1 parent 5bb7e42 commit d4812c3

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

temporalio/worker/_workflow_instance.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -856,11 +856,10 @@ def _apply_resolve_nexus_operation_start(
856856
raise RuntimeError(
857857
f"Failed to find nexus operation handle for job sequence number {job.seq}"
858858
)
859-
# TODO(dan): change core protos to use operation_token instead of operation_id
860-
if job.HasField("operation_id"):
859+
if job.HasField("operation_token"):
861860
# The Nexus operation started asynchronously. A `ResolveNexusOperation` job
862861
# will follow in a future activation.
863-
handle._resolve_start_success(job.operation_id)
862+
handle._resolve_start_success(job.operation_token)
864863
elif job.HasField("started_sync"):
865864
# The Nexus operation 'started' in the sense that it's already resolved. A
866865
# `ResolveNexusOperation` job will be in the same activation.

0 commit comments

Comments
 (0)