You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by jo...@apache.org on 2022/07/22 21:05:23 UTC
[airflow] branch main updated: Fix BatchOperator links on wait_for_completion = True (#25228)
This is an automated email from the ASF dual-hosted git repository.
joshfell pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new ceb1658565 Fix BatchOperator links on wait_for_completion = True (#25228)
ceb1658565 is described below
commit ceb16585659034771afd97b580928c547d46adfe
Author: Andrey Anshin <An...@taragol.is>
AuthorDate: Sat Jul 23 01:05:17 2022 +0400
Fix BatchOperator links on wait_for_completion = True (#25228)
---
airflow/providers/amazon/aws/operators/batch.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/providers/amazon/aws/operators/batch.py b/airflow/providers/amazon/aws/operators/batch.py
index b74d47ea30..4db83ecf78 100644
--- a/airflow/providers/amazon/aws/operators/batch.py
+++ b/airflow/providers/amazon/aws/operators/batch.py
@@ -115,7 +115,7 @@ class BatchOperator(BaseOperator):
def operator_extra_links(self):
op_extra_links = [BatchJobDetailsLink()]
if self.wait_for_completion:
- op_extra_links.extend(BatchJobDefinitionLink(), BatchJobQueueLink())
+ op_extra_links.extend([BatchJobDefinitionLink(), BatchJobQueueLink()])
if not self.array_properties:
# There is no CloudWatch Link to the parent Batch Job available.
op_extra_links.append(CloudWatchEventsLink())