The GitHub Actions job "Tests (AMD)" on airflow.git/shared-stream-ack has 
failed.
Run started by GitHub user Lee-W (triggered by Lee-W).

Head commit for run:
c3b856bbc32efe426995e4af8340f09f498ba09a / Wei Lee <[email protected]>
feat(triggers): add producer-side ack channel to shared-stream triggers

Extend the SharedStreamManager + BaseEventTrigger shared-stream API from
PR #66584 so it can also host upstreams that need a producer-held handle
to advance (Kafka manual commit, SQS delete / visibility extend, Pub/Sub
ack_id, Service Bus peek-lock).

Producer triggers opt in by overriding the new
`BaseEventTrigger.advance_shared_stream` classmethod and yielding
`(event, broker_payload)` tuples from `open_shared_stream`. Subscribers
receive an `AckToken` alongside each raw event; the manager invokes the
producer's advance hook once all subscribers in scope at fan-out time
have called `await token.ack()`. Triggers that don't override the hook
keep the existing fast path (subscribers see raw events, no ack table),
so `DirectoryFileDeleteTrigger` is unaffected.

Slow subscribers are bounded by a per-event ack timeout
(`SharedStreamManager(ack_timeout=...)`, default 300s); a single slow
subscriber is force-failed via the existing `_PollFailure` path without
blocking siblings. Broker advance failures are logged via
`_on_advance_done` rather than swallowed.

Closes #67179

Report URL: https://github.com/apache/airflow/actions/runs/26517698116

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to