tests.system.providers.apache.kylin.example_kylin_dag

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

Module Contents

Functions

gen_build_time()

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

Attributes

ENV_ID

DAG_ID

test_run

tests.system.providers.apache.kylin.example_kylin_dag.ENV_ID[source]
tests.system.providers.apache.kylin.example_kylin_dag.DAG_ID = example_kylin_operator[source]
tests.system.providers.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.providers.apache.kylin.example_kylin_dag.test_run[source]

Was this entry helpful?