:mod:`airflow.sensors.sql_sensor` ================================= .. py:module:: airflow.sensors.sql_sensor Module Contents --------------- .. py:class:: SqlSensor(conn_id, sql, parameters=None, *args, **kwargs) Bases::class:`airflow.sensors.base_sensor_operator.BaseSensorOperator` Runs a sql statement until a criteria is met. It will keep trying while sql returns no row, or if the first cell in (0, '0', ''). :param conn_id: The connection to run the sensor against :type conn_id: str :param sql: The sql to run. To pass, it needs to return at least one cell that contains a non-zero / empty string value. :type sql: str :param parameters: The parameters to render the SQL query with (optional). :type parameters: mapping or iterable .. attribute:: template_fields :annotation: = ['sql'] .. attribute:: template_ext :annotation: = ['.hql', '.sql'] .. attribute:: ui_color :annotation: = #7c7287 .. method:: poke(self, context)