Complete the airflow survey & get a free airflow 3 certification!

tests.system.apache.kylin.example_kylin_dag¶

This is an example DAG which uses the KylinCubeOperator. The tasks below include kylin build, refresh, merge operation.

Attributes¶

`ENV_ID`
`DAG_ID`
`test_run`

Functions¶

gen_build_time()

Gen build time and push to XCom (with key of "return_value")

Module Contents¶

tests.system.apache.kylin.example_kylin_dag.ENV_ID[source]¶

tests.system.apache.kylin.example_kylin_dag.DAG_ID = 'example_kylin_operator'[source]¶

tests.system.apache.kylin.example_kylin_dag.gen_build_time()[source]¶: Gen build time and push to XCom (with key of “return_value”) :return: A dict with build time values.

tests.system.apache.kylin.example_kylin_dag.test_run[source]¶

Was this entry helpful?