tests.system.teradata.example_teradata

Example Airflow DAG to show usage of TeradataOperator.

This DAG assumes Airflow Connection with connection id teradata_default already exists in locally. It shows how to use create, update, delete and select teradata statements with TeradataOperator as tasks in airflow dags using TeradataStoredProcedureOperator.

Module Contents

tests.system.teradata.example_teradata.ENV_ID[source]
tests.system.teradata.example_teradata.DAG_ID = 'example_teradata'[source]
tests.system.teradata.example_teradata.CONN_ID = 'teradata_default'[source]
tests.system.teradata.example_teradata.create_table[source]
tests.system.teradata.example_teradata.test_run[source]

Was this entry helpful?