You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by el...@apache.org on 2021/03/21 13:42:24 UTC

[airflow] branch master updated: fix deprecated import path of tests (#14923)

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

eladkal 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 fc32d36  fix deprecated import path of tests (#14923)
fc32d36 is described below

commit fc32d36d44f9d36b30333ce0676f2f3a6b133619
Author: eladkal <45...@users.noreply.github.com>
AuthorDate: Sun Mar 21 15:42:01 2021 +0200

    fix deprecated import path of tests (#14923)
---
 tests/jobs/test_local_task_job.py                     | 2 +-
 tests/operators/test_sql.py                           | 2 +-
 tests/ti_deps/deps/test_not_previously_skipped_dep.py | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/tests/jobs/test_local_task_job.py b/tests/jobs/test_local_task_job.py
index a4cbff6..f716766 100644
--- a/tests/jobs/test_local_task_job.py
+++ b/tests/jobs/test_local_task_job.py
@@ -34,7 +34,7 @@ from airflow.jobs.local_task_job import LocalTaskJob
 from airflow.models.dag import DAG
 from airflow.models.dagbag import DagBag
 from airflow.models.taskinstance import TaskInstance
-from airflow.operators.dummy_operator import DummyOperator
+from airflow.operators.dummy import DummyOperator
 from airflow.operators.python import PythonOperator
 from airflow.task.task_runner.standard_task_runner import StandardTaskRunner
 from airflow.utils import timezone
diff --git a/tests/operators/test_sql.py b/tests/operators/test_sql.py
index 411daf6..099e0e6 100644
--- a/tests/operators/test_sql.py
+++ b/tests/operators/test_sql.py
@@ -24,7 +24,7 @@ import pytest
 
 from airflow.exceptions import AirflowException
 from airflow.models import DAG, Connection, DagRun, TaskInstance as TI
-from airflow.operators.dummy_operator import DummyOperator
+from airflow.operators.dummy import DummyOperator
 from airflow.operators.sql import (
     BranchSQLOperator,
     SQLCheckOperator,
diff --git a/tests/ti_deps/deps/test_not_previously_skipped_dep.py b/tests/ti_deps/deps/test_not_previously_skipped_dep.py
index 20f4325..a600df2 100644
--- a/tests/ti_deps/deps/test_not_previously_skipped_dep.py
+++ b/tests/ti_deps/deps/test_not_previously_skipped_dep.py
@@ -20,7 +20,7 @@ import pendulum
 
 from airflow.models import DAG, DagRun, TaskInstance
 from airflow.operators.dummy import DummyOperator
-from airflow.operators.python_operator import BranchPythonOperator
+from airflow.operators.python import BranchPythonOperator
 from airflow.ti_deps.dep_context import DepContext
 from airflow.ti_deps.deps.not_previously_skipped_dep import NotPreviouslySkippedDep
 from airflow.utils.session import create_session