Bert Desmet created AIRFLOW-3107:
------------------------------------

             Summary: Create Dynamic External Task Sensor to handle non exact 
timeframes
                 Key: AIRFLOW-3107
                 URL: https://issues.apache.org/jira/browse/AIRFLOW-3107
             Project: Apache Airflow
          Issue Type: New Feature
          Components: core
    Affects Versions: 1.10.0
            Reporter: Bert Desmet
             Fix For: 1.10.0


All, 

For a project I'm working on it is necessary to check if a specific task has 
run somewhere between 30 days ago and now. 

To facilitate this I have patched airflow to include the 
'TimeRangeExternalTaskSensor'  as provided by 
{color:#333333}[omnilinguist|https://github.com/omnilinguist] in the following 
pull request: [https://github.com/apache/incubator-airflow/pull/1641] {color}

I have updated his code so it aligns better with how the ExternalTaskSensor has 
been implemented. 

Currently we are running this patch in production on a 1.9 version of Airflow. 
I have now merged this with the master branch - but this code has not yet fully 
been tested. 

 

The code can be found here:  
[https://github.com/biertie/incubator-airflow/blob/master/airflow/sensors/time_range_external_task_sensor.py]

 

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to