blob: ade8204e6b013b0ed1614a44048502e980617300 [file] [log] [blame]
:py:mod:`tests.system.providers.google.cloud.dataproc.example_dataproc_pig`
===========================================================================
.. py:module:: tests.system.providers.google.cloud.dataproc.example_dataproc_pig
.. autoapi-nested-parse::
Example Airflow DAG for DataprocSubmitJobOperator with pig job.
Module Contents
---------------
.. py:data:: ENV_ID
.. py:data:: DAG_ID
:annotation: = dataproc_pig
.. py:data:: PROJECT_ID
.. py:data:: CLUSTER_NAME
.. py:data:: REGION
:annotation: = europe-west1
.. py:data:: ZONE
:annotation: = europe-west1-b
.. py:data:: CLUSTER_CONFIG
.. py:data:: TIMEOUT
.. py:data:: PIG_JOB
.. py:data:: create_cluster
.. py:data:: test_run