• Home
• Index

Index

_

__version__ (in module airflow.providers.common.messaging)

A

airflow.providers.common.messaging module airflow.providers.common.messaging.get_provider_info module airflow.providers.common.messaging.providers.base_provider module

airflow.providers.common.messaging.triggers module airflow.providers.common.messaging.triggers.msg_queue module asset (in module tests.system.common.messaging.example_message_queue_trigger)

B

BaseMessageQueueProvider (class in airflow.providers.common.messaging.providers.base_provider)

C

create_class_by_name() (in module airflow.providers.common.messaging.triggers.msg_queue)

G

get_provider_info() (in module airflow.providers.common.messaging.get_provider_info)

K

kwargs (airflow.providers.common.messaging.triggers.msg_queue.MessageQueueTrigger attribute)

M

MESSAGE_QUEUE_PROVIDERS (in module airflow.providers.common.messaging.triggers.msg_queue) MessageQueueTrigger (class in airflow.providers.common.messaging.triggers.msg_queue) module airflow.providers.common.messaging airflow.providers.common.messaging.get_provider_info airflow.providers.common.messaging.providers.base_provider airflow.providers.common.messaging.triggers airflow.providers.common.messaging.triggers.msg_queue tests.system.common.messaging tests.system.common.messaging.example_message_queue_trigger

P

providers_manager (in module airflow.providers.common.messaging.triggers.msg_queue)

Q

queue (airflow.providers.common.messaging.triggers.msg_queue.MessageQueueTrigger attribute)

queue_matches() (airflow.providers.common.messaging.providers.base_provider.BaseMessageQueueProvider method)

R

run() (airflow.providers.common.messaging.triggers.msg_queue.MessageQueueTrigger method)

S

scheme (airflow.providers.common.messaging.providers.base_provider.BaseMessageQueueProvider attribute) (airflow.providers.common.messaging.triggers.msg_queue.MessageQueueTrigger attribute)

scheme_matches() (airflow.providers.common.messaging.providers.base_provider.BaseMessageQueueProvider method) serialize() (airflow.providers.common.messaging.triggers.msg_queue.MessageQueueTrigger method)

T

test_run (in module tests.system.common.messaging.example_message_queue_trigger) tests.system.common.messaging module tests.system.common.messaging.example_message_queue_trigger module

trigger (airflow.providers.common.messaging.triggers.msg_queue.MessageQueueTrigger property) (in module tests.system.common.messaging.example_message_queue_trigger) trigger_class() (airflow.providers.common.messaging.providers.base_provider.BaseMessageQueueProvider method) trigger_kwargs() (airflow.providers.common.messaging.providers.base_provider.BaseMessageQueueProvider method)

PreviousNext

Was this entry helpful?