Example Airflow DAG that uses Google PubSub services.
Module Contents
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.ENV_ID[source]
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.PROJECT_ID[source]
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.DAG_ID = 'pubsub_async'[source]
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.TOPIC_ID[source]
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.MESSAGE[source]
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.create_topic[source]
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.test_run[source]