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