tests.system.apache.cassandra.example_cassandra_dag
示例 Airflow DAG，用于使用 CassandraTableSensor 和 CassandraRecordSensor 检查 Cassandra Table 和 Records 是否存在。
模块内容
-
tests.system.apache.cassandra.example_cassandra_dag.ENV_ID[source]
-
tests.system.apache.cassandra.example_cassandra_dag.DAG_ID = 'example_cassandra_operator'[source]
-
tests.system.apache.cassandra.example_cassandra_dag.table_sensor[source]
-
tests.system.apache.cassandra.example_cassandra_dag.test_run[source]