Fix compat-test failures from asserting on unreleased MessageQueueTrigger.queue

Provider distributions must keep passing tests against previously
released Airflow versions. BaseEventTrigger.queue is a new attribute
added by this branch, so any Airflow release before it ships doesn't
have the attribute at all, and BaseTrigger has no class-level default
either in those older releases. Assertions on trigger.queue therefore
raised AttributeError under the 3.0.6/3.1.8/3.3.0 compat test jobs.
Guard with getattr(trigger, "queue", None), matching the same pattern
already used for this attribute in airflow.serialization.encoders.

Author: zach-overflow

providers/common/messaging/tests/unit/common/messaging/triggers/test_msg_queue.py

@@ -229,14 +229,15 @@ def test_scheme_only_initialization(self):
     def test_deprecated_queue_param_does_not_set_triggerer_queue(self):
         """Regression test: the deprecated `queue` (broker URI) must not leak into the unrelated
         `BaseEventTrigger.queue` attribute used for triggerer queue assignment (see #71346), or the
-        resulting Trigger row would never be picked up by any triggerer."""
+        resulting Trigger row would never be picked up by any triggerer. `BaseEventTrigger.queue` is
+        only present on Airflow versions that ship #71346, hence the `getattr` default."""
         trigger = MessageQueueTrigger(queue=PROVIDER_1_QUEUE)
         assert trigger.queue_uri == PROVIDER_1_QUEUE
-        assert trigger.queue is None
+        assert getattr(trigger, "queue", None) is None
 
     def test_scheme_param_does_not_set_triggerer_queue(self):
         trigger = MessageQueueTrigger(scheme=PROVIDER_2_SCHEME)
-        assert trigger.queue is None
+        assert getattr(trigger, "queue", None) is None
 
     def test_scheme_provider_matching(self):
         """Test that scheme matching works correctly."""

providers/ibm/mq/tests/unit/ibm/mq/queues/test_mq.py

@@ -228,7 +228,7 @@ def test_message_queue_trigger_with_scheme(self):
             mq_conn_id="mq_default",
             queue_name="MY.QUEUE.NAME",
         )
-        assert trigger.queue is None
+        assert getattr(trigger, "queue", None) is None
         assert trigger.scheme == "ibmmq"
         assert isinstance(trigger.trigger, AwaitMessageTrigger)
         assert trigger.trigger.mq_conn_id == "mq_default"
@@ -242,7 +242,7 @@ def test_message_queue_trigger_with_deprecated_queue(self):
         trigger = MessageQueueTrigger(queue="ibmmq://mq_default/MY.QUEUE.NAME", open_options=32)
         assert trigger.scheme is None
         assert trigger.queue_uri == "ibmmq://mq_default/MY.QUEUE.NAME"
-        assert trigger.queue is None
+        assert getattr(trigger, "queue", None) is None
         assert isinstance(trigger.trigger, AwaitMessageTrigger)
         assert trigger.trigger.mq_conn_id == "mq_default"
         assert trigger.trigger.queue_name == "MY.QUEUE.NAME"