https://github.com/apache/airflow/blob/fdd9b6f65b608c516b8a062b058972d9a45ec9e3/airflow/sensors/sql_sensor.py#L97


tests/sensors/test_sql_sensor.py
#
#
#
import os
import unittest
from unittest import mock
import pytest
from airflow.exceptions import AirflowException
from airflow.models.dag import DAG
from airflow.sensors.sql_sensor import SqlSensor
from airflow.utils.timezone import datetime
from tests.providers.apache.hive import TestHiveEnvironment
DEFAULT_DATE = datetime(2015, 1, 1)
TEST_DAG_ID = 'unit_test_sql_dag'
class TestSqlSensor(TestHiveEnvironment):
    def setUp(self):
        super().setUp()
        args = {'owner': 'airflow', 'start_date': DEFAULT_DATE}
        self.dag = DAG(TEST_DAG_ID, default_args=args)
    def test_unsupported_conn_type(self):