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 <[email protected]>
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())
