`airflow.providers.google.cloud.example_dags.example_dataflow_flex_template`¶

Example Airflow DAG for Google Cloud Dataflow service

Module Contents¶

airflow.providers.google.cloud.example_dags.example_dataflow_flex_template.GCP_PROJECT_ID[source]¶

airflow.providers.google.cloud.example_dags.example_dataflow_flex_template.DATAFLOW_FLEX_TEMPLATE_JOB_NAME[source]¶

airflow.providers.google.cloud.example_dags.example_dataflow_flex_template.PUBSUB_FLEX_TEMPLATE_TOPIC[source]¶

airflow.providers.google.cloud.example_dags.example_dataflow_flex_template.PUBSUB_FLEX_TEMPLATE_SUBSCRIPTION[source]¶

airflow.providers.google.cloud.example_dags.example_dataflow_flex_template.GCS_FLEX_TEMPLATE_TEMPLATE_PATH[source]¶

airflow.providers.google.cloud.example_dags.example_dataflow_flex_template.BQ_FLEX_TEMPLATE_DATASET[source]¶

airflow.providers.google.cloud.example_dags.example_dataflow_flex_template.BQ_FLEX_TEMPLATE_LOCATION[source]¶

airflow.providers.google.cloud.example_dags.example_dataflow_flex_template.start_flex_template[source]¶

Was this entry helpful?