Skip to content
  • Aleksandar Mastilovic's avatar
    Replace task_sequence with Airflow chain operator · b3a0ec5d
    Aleksandar Mastilovic authored
    * Sensor has to go in the chain, too
    
    cassandra_load_commons_impact_metrics_dag wouldn't load because chain
    itself can't be chained to an operator/sensor.
    
    Added a DAG load test for that DAG, too.
    
    * Replace task_sequence with Airflow chain operator
    
    Custom util function task_sequence performs the exact same function as
    the chain operator provided by Airflow itself.
    b3a0ec5d