You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ka...@apache.org on 2021/01/05 21:34:46 UTC

[airflow] branch master updated: Fix failing backport packages test (#13497)

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

kaxilnaik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/master by this push:
     new 003584b  Fix failing backport packages test (#13497)
003584b is described below

commit 003584bbf1d66a3545ad6e6fcdceb0410fc83696
Author: Kaxil Naik <ka...@gmail.com>
AuthorDate: Tue Jan 5 21:34:35 2021 +0000

    Fix failing backport packages test (#13497)
    
    In #13473 - I updated the deprecated packages but looks like it broke backport packages:
    
    ```
        File "/usr/local/lib/python3.6/site-packages/airflow/providers/google/cloud/example_dags/example_tasks.py", line 32, in <module>
          from airflow.models.baseoperator import chain
      ImportError: cannot import name 'chain'
    ```
---
 airflow/providers/google/cloud/example_dags/example_tasks.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/providers/google/cloud/example_dags/example_tasks.py b/airflow/providers/google/cloud/example_dags/example_tasks.py
index 82335de..dc1f1e3 100644
--- a/airflow/providers/google/cloud/example_dags/example_tasks.py
+++ b/airflow/providers/google/cloud/example_dags/example_tasks.py
@@ -29,7 +29,6 @@ from google.cloud.tasks_v2.types import Queue
 from google.protobuf import timestamp_pb2
 
 from airflow import models
-from airflow.models.baseoperator import chain
 from airflow.operators.bash import BashOperator
 from airflow.providers.google.cloud.operators.tasks import (
     CloudTasksQueueCreateOperator,
@@ -47,6 +46,7 @@ from airflow.providers.google.cloud.operators.tasks import (
     CloudTasksTasksListOperator,
 )
 from airflow.utils.dates import days_ago
+from airflow.utils.helpers import chain
 
 timestamp = timestamp_pb2.Timestamp()
 timestamp.FromDatetime(datetime.now() + timedelta(hours=12))  # pylint: disable=no-member