Example Airflow DAG for testing Google Dataflow Beam Pipeline Operator with Python.
Module Contents
-
tests.system.providers.google.cloud.dataflow.example_dataflow_native_python.ENV_ID[source]
-
tests.system.providers.google.cloud.dataflow.example_dataflow_native_python.DAG_ID = 'dataflow_native_python'[source]
-
tests.system.providers.google.cloud.dataflow.example_dataflow_native_python.RESOURCE_DATA_BUCKET = 'airflow-system-tests-resources'[source]
-
tests.system.providers.google.cloud.dataflow.example_dataflow_native_python.BUCKET_NAME[source]
-
tests.system.providers.google.cloud.dataflow.example_dataflow_native_python.GCS_TMP[source]
-
tests.system.providers.google.cloud.dataflow.example_dataflow_native_python.GCS_STAGING[source]
-
tests.system.providers.google.cloud.dataflow.example_dataflow_native_python.GCS_OUTPUT[source]
-
tests.system.providers.google.cloud.dataflow.example_dataflow_native_python.GCS_PYTHON_SCRIPT[source]
-
tests.system.providers.google.cloud.dataflow.example_dataflow_native_python.LOCATION = 'europe-west3'[source]
-
tests.system.providers.google.cloud.dataflow.example_dataflow_native_python.default_args[source]
-
tests.system.providers.google.cloud.dataflow.example_dataflow_native_python.create_bucket[source]
-
tests.system.providers.google.cloud.dataflow.example_dataflow_native_python.test_run[source]