[
https://issues.apache.org/jira/browse/AIRFLOW-4568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17101669#comment-17101669
]
ASF subversion and git services commented on AIRFLOW-4568:
----------------------------------------------------------
Commit 6e4f5fa66ebe2d8252829c67e79f895fa5029b5a in airflow's branch
refs/heads/master from Lokesh Lal
[ https://gitbox.apache.org/repos/asf?p=airflow.git;h=6e4f5fa ]
[AIRFLOW-4568]The ExternalTaskSensor should be configurable to raise an Airflow
Exception in case the poked external task reaches a disallowed state, such as
f.i. failed (#8509)
Added failed_states for ExternalTaskSensor to avoid waiting for the failure
scenarios till timeout value
> The ExternalTaskSensor should be configurable to raise an Airflow Exception
> in case the poked external task reaches a disallowed state, such as f.i.
> failed
> -----------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: AIRFLOW-4568
> URL: https://issues.apache.org/jira/browse/AIRFLOW-4568
> Project: Apache Airflow
> Issue Type: Improvement
> Components: operators
> Affects Versions: 1.10.3
> Reporter: ddluke
> Priority: Minor
>
> _As an engineer, I would like to have the behavior of the ExternalTaskSensor
> changed_
> _So that it fails in case the poked external_task_id fails_
> *Therefore*
> * I suggest extending the behavior of the sensor to optionally also query
> the TaskInstance for disallowed states and raise an AirflowException if
> found. Currently, if the poked external task reaches a failed state, the
> sensor continues to poke and does not terminate
> *Acceptance Criteria (from my pov)*
> * The class interface for ExternalTaskSensor is extended with an additional
> parameter, disallowed_states, which is an Optional List of
> airflow.utils.state.State
> * The poke method is expanded to count the number of rows from TaskInstance
> which met the filter criteria dag_id, task_id, disallowed_states and
> dttm_filter if disallowed_states is not None
> * If disallowed_states is not None and the above query returns a counter >
> 0, an Airflow Exception is thrown
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
