arifrhm opened a new pull request, #77046: URL: https://github.com/apache/airflow/pull/77046
closes: #76554 ### What? * Repurposes `queue` on `MessageQueueTrigger` to route to trigger queues when used with `scheme` or `queue_uri`, aligning with `BaseEventTrigger(queue=...)` and other event triggers. * Deprecates `trigger_queue` in favor of `queue` with `AirflowProviderDeprecationWarning` for one transition cycle. * Raises `ValueError` if both `queue` and deprecated `trigger_queue` are provided. * Retains backward compatibility for legacy broker URI usage when neither `scheme` nor `queue_uri` is specified, emitting `AirflowProviderDeprecationWarning`. * Adds comprehensive unit tests covering `queue` routing, deprecation warnings, and conflict validation. ### Why? * PR #71346 added trigger queue routing for event-based triggers. On most triggers, `queue` routes to a triggerer. However, on `MessageQueueTrigger`, `queue` previously kept its old deprecated meaning (broker queue URI), forcing triggerer routing to use `trigger_queue` instead. * `MessageQueueTrigger` is the trigger most Asset Watcher users configure, so `queue=` there silently did something different from everywhere else. * This unifies `queue` on `MessageQueueTrigger` with the rest of the trigger interfaces in Airflow. --- ##### Was generative AI tooling used to co-author this PR? - [ ] Yes (please specify the tool below) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
