Skip to content

Commit e6ea670

Browse files
authored
Moving EmptyOperator to standard provider (apache#46231)
1 parent bda4e78 commit e6ea670

File tree

161 files changed

+241
-201
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

161 files changed

+241
-201
lines changed

airflow/example_dags/example_bash_decorator.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
from airflow.decorators import dag, task
2323
from airflow.exceptions import AirflowSkipException
2424
from airflow.models.baseoperator import chain
25-
from airflow.operators.empty import EmptyOperator
25+
from airflow.providers.standard.operators.empty import EmptyOperator
2626
from airflow.utils.trigger_rule import TriggerRule
2727
from airflow.utils.weekday import WeekDay
2828

airflow/example_dags/example_bash_operator.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,8 @@
2424
import pendulum
2525

2626
from airflow.models.dag import DAG
27-
from airflow.operators.empty import EmptyOperator
2827
from airflow.providers.standard.operators.bash import BashOperator
28+
from airflow.providers.standard.operators.empty import EmptyOperator
2929

3030
with DAG(
3131
dag_id="example_bash_operator",

airflow/example_dags/example_branch_datetime_operator.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,8 @@
2525
import pendulum
2626

2727
from airflow.models.dag import DAG
28-
from airflow.operators.empty import EmptyOperator
2928
from airflow.providers.standard.operators.datetime import BranchDateTimeOperator
29+
from airflow.providers.standard.operators.empty import EmptyOperator
3030

3131
dag1 = DAG(
3232
dag_id="example_branch_datetime_operator",

airflow/example_dags/example_branch_day_of_week_operator.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
import pendulum
2525

2626
from airflow.models.dag import DAG
27-
from airflow.operators.empty import EmptyOperator
27+
from airflow.providers.standard.operators.empty import EmptyOperator
2828
from airflow.providers.standard.operators.weekday import BranchDayOfWeekOperator
2929
from airflow.utils.weekday import WeekDay
3030

airflow/example_dags/example_branch_labels.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
import pendulum
2525

2626
from airflow.models.dag import DAG
27-
from airflow.operators.empty import EmptyOperator
27+
from airflow.providers.standard.operators.empty import EmptyOperator
2828
from airflow.utils.edgemodifier import Label
2929

3030
with DAG(

airflow/example_dags/example_branch_operator.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
import pendulum
3131

3232
from airflow.models.dag import DAG
33-
from airflow.operators.empty import EmptyOperator
33+
from airflow.providers.standard.operators.empty import EmptyOperator
3434
from airflow.providers.standard.operators.python import (
3535
BranchExternalPythonOperator,
3636
BranchPythonOperator,

airflow/example_dags/example_branch_operator_decorator.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232

3333
from airflow.decorators import task
3434
from airflow.models.dag import DAG
35-
from airflow.operators.empty import EmptyOperator
35+
from airflow.providers.standard.operators.empty import EmptyOperator
3636
from airflow.utils.edgemodifier import Label
3737
from airflow.utils.trigger_rule import TriggerRule
3838

airflow/example_dags/example_branch_python_dop_operator_3.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626

2727
from airflow.decorators import task
2828
from airflow.models.dag import DAG
29-
from airflow.operators.empty import EmptyOperator
29+
from airflow.providers.standard.operators.empty import EmptyOperator
3030

3131

3232
@task.branch()

airflow/example_dags/example_display_name.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
import pendulum
2121

2222
from airflow.decorators import dag, task
23-
from airflow.operators.empty import EmptyOperator
23+
from airflow.providers.standard.operators.empty import EmptyOperator
2424

2525

2626
# [START dag_decorator_usage]

airflow/example_dags/example_external_task_marker_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@
4343
import pendulum
4444

4545
from airflow.models.dag import DAG
46-
from airflow.operators.empty import EmptyOperator
46+
from airflow.providers.standard.operators.empty import EmptyOperator
4747
from airflow.providers.standard.sensors.external_task import ExternalTaskMarker, ExternalTaskSensor
4848

4949
start_date = pendulum.datetime(2021, 1, 1, tz="UTC")

0 commit comments

Comments
 (0)