Как получить УСПЕХ в SqlSensor (Airflow), когда мой sql выдает мне нулевое значение - PullRequest
Новая
       37

Как получить УСПЕХ в SqlSensor (Airflow), когда мой sql выдает мне нулевое значение

0 голосов
/ 21 июня 2020

Как я могу получить значение УСПЕХ в SqlSensor (Airflow), когда мой sql выдает мне значение NULL, и если он получает некоторые записи, то FAIL? Нужно ли мне писать собственный SqlSensor, если да, то можете ли вы мне посоветовать, как это сделать? мой SqlSensor: 

sensor = SqlSensor(
    task_id='check_for_data_in_table',
    conn_id = O_CONN_ID,    
    timeout=3200,
    poke_interval=120,
    sql="""
      select column_c from test_table where column_b = to_date(trunc(sysdate))
    """,
    dag=dag)
...