Repository: incubator-airflow Updated Branches: refs/heads/master 5060d90db -> 9ebb04acb
[AIRFLOW-2735] Use equality, not identity, check for detecting AWS Batch failures[] Closes #3589 from craigforster/master Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/9ebb04ac Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/9ebb04ac Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/9ebb04ac Branch: refs/heads/master Commit: 9ebb04acbd07c208c30160bd28c342c569246e8f Parents: 5060d90 Author: Craig Forster <[email protected]> Authored: Tue Jul 10 10:03:09 2018 +0200 Committer: Fokko Driesprong <[email protected]> Committed: Tue Jul 10 10:03:09 2018 +0200 ---------------------------------------------------------------------- airflow/contrib/operators/awsbatch_operator.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/9ebb04ac/airflow/contrib/operators/awsbatch_operator.py ---------------------------------------------------------------------- diff --git a/airflow/contrib/operators/awsbatch_operator.py b/airflow/contrib/operators/awsbatch_operator.py index 75706aa..a5c86af 100644 --- a/airflow/contrib/operators/awsbatch_operator.py +++ b/airflow/contrib/operators/awsbatch_operator.py @@ -153,7 +153,7 @@ class AWSBatchOperator(BaseOperator): for job in response['jobs']: job_status = job['status'] - if job_status is 'FAILED': + if job_status == 'FAILED': reason = job['statusReason'] raise AirflowException('Job failed with status {}'.format(reason)) elif job_status in [
