Airflow Summit 2025 is coming October 07-09. Register now for early bird ticket!

Messaging Triggers

Operators, sensors, and triggers in the Common Messaging provider serve as wrappers around those from other providers, specifically for message queues. They offer an abstraction layer to simplify usage and make it easier to switch between different queue providers.

Add support for a provider

To support a new provider please follow the steps below:

1. Create a new class in the provider extending BaseMessageQueueProvider. Make sure it implements all abstract methods

2. Expose it via “queues” property in the provider.yaml file of the provider where you add the new class. The queues property should be a list of fully-qualified class names of the queues.

The list of supported message queues is available in Message Queues.

Was this entry helpful?