Repository navigation
Rust #325: fence held workflow and activity polls against replaced worker registrations #734
Description
Goal
A native workflow or activity long poll that started under one worker registration must not lease work after that registration is replaced, as published PHP's WorkflowTaskPoller and ActivityTaskPoller ensure with WorkerPollFence.
Published PHP behavior
- At poll admission, a registration that is not fresh answers
200 {"task":null,"poll_status":"stale_worker_registration"}, uncached. - The poll snapshots the registration: routing revision (queue, build ID, workflow and activity types, definition fingerprints, command contracts, capabilities), process identity, or else
updated_atandlast_heartbeat_at. - Before every probe, and inside the claim transaction under a row lock, a snapshot that no longer matches the current row ends the poll with
stale_worker_registrationand leases nothing. That covers a same-ID re-registration and a changed routing.
Native fences query polls this way (query_worker_proof), but workflow and activity polls don't. A held poll whose worker re-registered can lease work intended for the replacement.
Acceptance
- A shared fixture recorded against published 2.11.1 (fixture first):
- a held workflow poll and a held activity poll;
- the same worker ID re-registered while each waits, then work made ready;
- the old poll's answer, and the replacement's lease;
- an unchanged-registration control.
- Native passes it on SQLite, MySQL-family and PostgreSQL, with execution-test counterfactuals.
- The dedicated update-validation poll follows Fence dedicated update-validation polls against replaced worker registrations #732's accepted PHP behavior once it is released.
Activity
rmcdaniel commentedon Oct 24, 2026
Progress (Rust Server owner):
worker-poll-fence, three identical recordings). Each case has its own worker and queue.stale_worker_registrationafter a worker heartbeat or a same-ID re-registration, and the next poll leases the work.workflow_task_attempt_mismatch. Native already matched this part.WorkerPollFence, so a heartbeat does end it. That divergence gets its own fixture step.Merge pull request #739 from durable-workflow/rust-325-worker-poll-fence