tests.system.providers.google.cloud.dataflow.example_dataflow_sql

Example Airflow DAG for Google Cloud Dataflow service

Module Contents

tests.system.providers.google.cloud.dataflow.example_dataflow_sql.PROJECT_ID[source]
tests.system.providers.google.cloud.dataflow.example_dataflow_sql.ENV_ID[source]
tests.system.providers.google.cloud.dataflow.example_dataflow_sql.DAG_ID = 'example_dataflow_sql'[source]
tests.system.providers.google.cloud.dataflow.example_dataflow_sql.LOCATION = 'europe-west3'[source]
tests.system.providers.google.cloud.dataflow.example_dataflow_sql.DATAFLOW_SQL_JOB_NAME[source]
tests.system.providers.google.cloud.dataflow.example_dataflow_sql.BQ_SQL_DATASET[source]
tests.system.providers.google.cloud.dataflow.example_dataflow_sql.BQ_SQL_TABLE_INPUT[source]
tests.system.providers.google.cloud.dataflow.example_dataflow_sql.BQ_SQL_TABLE_OUTPUT[source]
tests.system.providers.google.cloud.dataflow.example_dataflow_sql.INSERT_ROWS_QUERY[source]
tests.system.providers.google.cloud.dataflow.example_dataflow_sql.create_bq_dataset[source]
tests.system.providers.google.cloud.dataflow.example_dataflow_sql.test_run[source]

Was this entry helpful?