tests.system.providers.google.cloud.pubsub.example_pubsub_deferrable

Example Airflow DAG that uses Google PubSub services.

Module Contents

tests.system.providers.google.cloud.pubsub.example_pubsub_deferrable.ENV_ID[source]
tests.system.providers.google.cloud.pubsub.example_pubsub_deferrable.PROJECT_ID[source]
tests.system.providers.google.cloud.pubsub.example_pubsub_deferrable.DAG_ID = 'pubsub_async'[source]
tests.system.providers.google.cloud.pubsub.example_pubsub_deferrable.TOPIC_ID[source]
tests.system.providers.google.cloud.pubsub.example_pubsub_deferrable.MESSAGE[source]
tests.system.providers.google.cloud.pubsub.example_pubsub_deferrable.create_topic[source]
tests.system.providers.google.cloud.pubsub.example_pubsub_deferrable.test_run[source]

Was this entry helpful?