[airflow] branch main updated: ECS Buglette (#26921)

[el...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

eladkal 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 d4bfccb3c9 ECS Buglette (#26921)
d4bfccb3c9 is described below

commit d4bfccb3c90d889863bb1d1500ad3158fc833aae
Author: D. Ferruzzi <fe...@amazon.com>
AuthorDate: Tue Oct 18 22:34:56 2022 -0700

    ECS Buglette (#26921)
    
    ECSTaskFlowFetcher incorrectly displayed a deprecation notice when used correctly.
---
 airflow/providers/amazon/aws/operators/ecs.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/providers/amazon/aws/operators/ecs.py b/airflow/providers/amazon/aws/operators/ecs.py
index 88b4aa0d71..fc301be263 100644
--- a/airflow/providers/amazon/aws/operators/ecs.py
+++ b/airflow/providers/amazon/aws/operators/ecs.py
@@ -536,7 +536,7 @@ class EcsRunTaskOperator(EcsBaseOperator):
             raise ValueError("must specify awslogs_group to fetch task logs")
         log_stream_name = f"{self.awslogs_stream_prefix}/{self.ecs_task_id}"
 
-        return EcsTaskLogFetcher(
+        return ecs.EcsTaskLogFetcher(
             aws_conn_id=self.aws_conn_id,
             region_name=self.awslogs_region,
             log_group=self.awslogs_group,