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())