| :mod:`airflow.contrib.sensors.cassandra_table_sensor` |
| ===================================================== |
| |
| .. py:module:: airflow.contrib.sensors.cassandra_table_sensor |
| |
| |
| Module Contents |
| --------------- |
| |
| .. py:class:: CassandraTableSensor(table, cassandra_conn_id, *args, **kwargs) |
| |
| Bases: :class:`airflow.sensors.base_sensor_operator.BaseSensorOperator` |
| |
| Checks for the existence of a table in a Cassandra cluster. |
| |
| For example, if you want to wait for a table called 't' to be created |
| in a keyspace 'k', instantiate it as follows: |
| |
| >>> cassandra_sensor = CassandraTableSensor(table="k.t", |
| ... cassandra_conn_id="cassandra_default", |
| ... task_id="cassandra_sensor") |
| |
| .. attribute:: template_fields |
| :annotation: = ['table'] |
| |
| |
| |
| |
| .. method:: poke(self, context) |
| |
| |
| |
| |
