apache · amoghrajesh · Feb 4, 2025 · Jan 29, 2025 · Jan 29, 2025 · Jan 29, 2025
diff --git a/airflow/example_dags/example_bash_decorator.py b/airflow/example_dags/example_bash_decorator.py
@@ -22,7 +22,7 @@
 from airflow.decorators import dag, task
 from airflow.exceptions import AirflowSkipException
 from airflow.models.baseoperator import chain
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.utils.trigger_rule import TriggerRule
 from airflow.utils.weekday import WeekDay
 

diff --git a/airflow/example_dags/example_bash_operator.py b/airflow/example_dags/example_bash_operator.py
@@ -24,8 +24,8 @@
 import pendulum
 
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
 from airflow.providers.standard.operators.bash import BashOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 
 with DAG(
     dag_id="example_bash_operator",

diff --git a/airflow/example_dags/example_branch_datetime_operator.py b/airflow/example_dags/example_branch_datetime_operator.py
@@ -25,8 +25,8 @@
 import pendulum
 
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
 from airflow.providers.standard.operators.datetime import BranchDateTimeOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 
 dag1 = DAG(
     dag_id="example_branch_datetime_operator",

diff --git a/airflow/example_dags/example_branch_day_of_week_operator.py b/airflow/example_dags/example_branch_day_of_week_operator.py
@@ -24,7 +24,7 @@
 import pendulum
 
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.providers.standard.operators.weekday import BranchDayOfWeekOperator
 from airflow.utils.weekday import WeekDay
 

diff --git a/airflow/example_dags/example_branch_labels.py b/airflow/example_dags/example_branch_labels.py
@@ -24,7 +24,7 @@
 import pendulum
 
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.utils.edgemodifier import Label
 
 with DAG(

diff --git a/airflow/example_dags/example_branch_operator.py b/airflow/example_dags/example_branch_operator.py
@@ -30,7 +30,7 @@
 import pendulum
 
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.providers.standard.operators.python import (
     BranchExternalPythonOperator,
     BranchPythonOperator,

diff --git a/airflow/example_dags/example_branch_operator_decorator.py b/airflow/example_dags/example_branch_operator_decorator.py
@@ -32,7 +32,7 @@
 
 from airflow.decorators import task
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.utils.edgemodifier import Label
 from airflow.utils.trigger_rule import TriggerRule
 

diff --git a/airflow/example_dags/example_branch_python_dop_operator_3.py b/airflow/example_dags/example_branch_python_dop_operator_3.py
@@ -26,7 +26,7 @@
 
 from airflow.decorators import task
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 
 
 @task.branch()

diff --git a/airflow/example_dags/example_display_name.py b/airflow/example_dags/example_display_name.py
@@ -20,7 +20,7 @@
 import pendulum
 
 from airflow.decorators import dag, task
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 
 
 # [START dag_decorator_usage]

diff --git a/airflow/example_dags/example_external_task_marker_dag.py b/airflow/example_dags/example_external_task_marker_dag.py
@@ -43,7 +43,7 @@
 import pendulum
 
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.providers.standard.sensors.external_task import ExternalTaskMarker, ExternalTaskSensor
 
 start_date = pendulum.datetime(2021, 1, 1, tz="UTC")

diff --git a/airflow/example_dags/example_latest_only.py b/airflow/example_dags/example_latest_only.py
@@ -22,7 +22,7 @@
 import datetime
 
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.providers.standard.operators.latest_only import LatestOnlyOperator
 
 with DAG(

diff --git a/airflow/example_dags/example_latest_only_with_trigger.py b/airflow/example_dags/example_latest_only_with_trigger.py
@@ -27,7 +27,7 @@
 import pendulum
 
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.providers.standard.operators.latest_only import LatestOnlyOperator
 from airflow.utils.trigger_rule import TriggerRule
 

diff --git a/airflow/example_dags/example_nested_branch_dag.py b/airflow/example_dags/example_nested_branch_dag.py
@@ -27,7 +27,7 @@
 
 from airflow.decorators import task
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.utils.trigger_rule import TriggerRule
 
 with DAG(

diff --git a/airflow/example_dags/example_short_circuit_decorator.py b/airflow/example_dags/example_short_circuit_decorator.py
@@ -22,7 +22,7 @@
 
 from airflow.decorators import dag, task
 from airflow.models.baseoperator import chain
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.utils.trigger_rule import TriggerRule
 
 

diff --git a/airflow/example_dags/example_short_circuit_operator.py b/airflow/example_dags/example_short_circuit_operator.py
@@ -23,7 +23,7 @@
 
 from airflow.models.baseoperator import chain
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.providers.standard.operators.python import ShortCircuitOperator
 from airflow.utils.trigger_rule import TriggerRule
 

diff --git a/airflow/example_dags/example_skip_dag.py b/airflow/example_dags/example_skip_dag.py
@@ -27,7 +27,7 @@
 from airflow.exceptions import AirflowSkipException
 from airflow.models.baseoperator import BaseOperator
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.utils.trigger_rule import TriggerRule
 
 if TYPE_CHECKING:

diff --git a/airflow/example_dags/example_task_group.py b/airflow/example_dags/example_task_group.py
@@ -22,8 +22,8 @@
 import pendulum
 
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
 from airflow.providers.standard.operators.bash import BashOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.utils.task_group import TaskGroup
 
 # [START howto_task_group]

diff --git a/airflow/example_dags/example_time_delta_sensor_async.py b/airflow/example_dags/example_time_delta_sensor_async.py
@@ -27,7 +27,7 @@
 import pendulum
 
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.providers.standard.sensors.time_delta import TimeDeltaSensorAsync
 
 with DAG(

diff --git a/airflow/example_dags/example_workday_timetable.py b/airflow/example_dags/example_workday_timetable.py
@@ -20,7 +20,7 @@
 
 from airflow.example_dags.plugins.workday import AfterWorkdayTimetable
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 
 with DAG(
     dag_id="example_workday_timetable",

diff --git a/docs/apache-airflow/administration-and-deployment/lineage.rst b/docs/apache-airflow/administration-and-deployment/lineage.rst
@@ -37,7 +37,7 @@ works.
     from airflow.models import DAG
     from airflow.providers.common.compat.lineage.entities import File
     from airflow.providers.standard.operators.bash import BashOperator
-    from airflow.operators.empty import EmptyOperator
+    from airflow.providers.standard.operators.empty import EmptyOperator
 
     FILE_CATEGORIES = ["CAT1", "CAT2", "CAT3"]
 

diff --git a/docs/apache-airflow/administration-and-deployment/logging-monitoring/callbacks.rst b/docs/apache-airflow/administration-and-deployment/logging-monitoring/callbacks.rst
@@ -66,7 +66,7 @@ In the following example, failures in any task call the ``task_failure_alert`` f
     import pendulum
 
     from airflow import DAG
-    from airflow.operators.empty import EmptyOperator
+    from airflow.providers.standard.operators.empty import EmptyOperator
 
 
     def task_failure_alert(context):

diff --git a/docs/apache-airflow/core-concepts/dags.rst b/docs/apache-airflow/core-concepts/dags.rst
@@ -43,7 +43,7 @@ which will add anything inside it to the DAG implicitly:
     import datetime
 
     from airflow import DAG
-    from airflow.operators.empty import EmptyOperator
+    from airflow.providers.standard.operators.empty import EmptyOperator
 
     with DAG(
         dag_id="my_dag_name",
@@ -61,7 +61,7 @@ Or, you can use a standard constructor, passing the DAG into any operators you u
     import datetime
 
     from airflow import DAG
-    from airflow.operators.empty import EmptyOperator
+    from airflow.providers.standard.operators.empty import EmptyOperator
 
     my_dag = DAG(
         dag_id="my_dag_name",
@@ -79,7 +79,7 @@ Or, you can use the ``@dag`` decorator to :ref:`turn a function into a DAG gener
     import datetime
 
     from airflow.decorators import dag
-    from airflow.operators.empty import EmptyOperator
+    from airflow.providers.standard.operators.empty import EmptyOperator
 
 
     @dag(start_date=datetime.datetime(2021, 1, 1), schedule="@daily")
@@ -455,7 +455,7 @@ You can also combine this with the :ref:`concepts:depends-on-past` functionality
 
         from airflow.decorators import task
         from airflow.models import DAG
-        from airflow.operators.empty import EmptyOperator
+        from airflow.providers.standard.operators.empty import EmptyOperator
 
         dag = DAG(
             dag_id="branch_without_trigger",
@@ -575,7 +575,7 @@ TaskGroup also supports ``default_args`` like DAG, it will overwrite the ``defau
     from airflow import DAG
     from airflow.decorators import task_group
     from airflow.providers.standard.operators.bash import BashOperator
-    from airflow.operators.empty import EmptyOperator
+    from airflow.providers.standard.operators.empty import EmptyOperator
 
     with DAG(
         dag_id="dag1",

diff --git a/docs/apache-airflow/howto/timetable.rst b/docs/apache-airflow/howto/timetable.rst
@@ -196,7 +196,7 @@ For reference, here's our plugin and DAG files in their entirety:
 
     from airflow import DAG
     from airflow.example_dags.plugins.workday import AfterWorkdayTimetable
-    from airflow.operators.empty import EmptyOperator
+    from airflow.providers.standard.operators.empty import EmptyOperator
 
 
     with DAG(

diff --git a/docs/apache-airflow/operators-and-hooks-ref.rst b/docs/apache-airflow/operators-and-hooks-ref.rst
@@ -53,7 +53,7 @@ For details see: :doc:`apache-airflow-providers:operators-and-hooks-ref/index`.
    * - :mod:`airflow.operators.branch`
      -
 
-   * - :mod:`airflow.operators.empty`
+   * - :mod:`airflow.providers.standard.operators.empty`
      -
 
    * - :mod:`airflow.operators.email`

diff --git a/docs/docker-stack/docker-examples/extending/embedding-dags/test_dag.py b/docs/docker-stack/docker-examples/extending/embedding-dags/test_dag.py
@@ -25,7 +25,7 @@
 import pendulum
 
 from airflow.models.dag import DAG
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 
 now = pendulum.now(tz="UTC")
 now_to_the_hour = (now - datetime.timedelta(0, 0, 0, 0, 0, 3)).replace(minute=0, second=0, microsecond=0)

diff --git a/newsfragments/41368.significant.rst b/newsfragments/41368.significant.rst
@@ -30,10 +30,10 @@ For example, instead of ``from airflow.sensors import TimeDeltaSensor``, use ``f
 
       * [x] ``airflow.operators.bash_operator.BashOperator`` → ``airflow.operators.bash.BashOperator``
       * [x] ``airflow.operators.branch_operator.BaseBranchOperator`` → ``airflow.operators.branch.BaseBranchOperator``
-      * [x] ``airflow.operators....EmptyOperator`` → ``airflow.operators.empty.EmptyOperator``
-      * [x] ``airflow.operators....DummyOperator`` → ``airflow.operators.empty.EmptyOperator``
-      * [x] ``airflow.operators.dummy_operator.EmptyOperator`` → ``airflow.operators.empty.EmptyOperator``
-      * [x] ``airflow.operators.dummy_operator.DummyOperator`` → ``airflow.operators.empty.EmptyOperator``
+      * [ ] ``airflow.operators....EmptyOperator`` → ``airflow.providers.standard.operators.empty.EmptyOperator``
+      * [ ] ``airflow.operators....DummyOperator`` → ``airflow.providers.standard.operators.empty.EmptyOperator``
+      * [ ] ``airflow.operators.dummy_operator.EmptyOperator`` → ``airflow.providers.standard.operators.empty.EmptyOperator``
+      * [ ] ``airflow.operators.dummy_operator.DummyOperator`` → ``airflow.providers.standard.operators.empty.EmptyOperator``
       * [x] ``airflow.operators.email_operator.EmailOperator`` → ``airflow.operators.email.EmailOperator``
       * [x] ``airflow.sensors.base_sensor_operator.BaseSensorOperator`` → ``airflow.sensors.base.BaseSensorOperator``
       * [x] ``airflow.sensors.date_time_sensor.DateTimeSensor`` → ``airflow.sensors.date_time.DateTimeSensor``

diff --git a/newsfragments/46231.significant.rst b/newsfragments/46231.significant.rst
@@ -0,0 +1,25 @@
+.. Moving EmptyOperator from Airflow core to the ``standard`` provider.
+
+.. EmptyOperator has been moved from Airflow core (``airflow.operators directory``) to the ``standard`` provider.
+For new and existing DAGs, users must import ``EmptyOperator`` from ``airflow.providers.standard.operators.empty``.
+
+* Types of change
+
+  * [x] Dag changes
+  * [ ] Config changes
+  * [ ] API changes
+  * [ ] CLI changes
+  * [ ] Behaviour changes
+  * [ ] Plugin changes
+  * [ ] Dependency changes
+  * [ ] Code interface changes
+
+.. List the migration rules needed for this change (see https://github.com/apache/airflow/issues/41641)
+
+* Migration rules needed
+
+  * ruff
+
+    * AIR302
+
+      * [ ] ``airflow.operators....EmptyOperator`` → ``airflow.providers.standard.operators.empty.EmptyOperator``
diff --git a/providers/apprise/tests/provider_tests/apprise/notifications/test_apprise.py b/providers/apprise/tests/provider_tests/apprise/notifications/test_apprise.py
@@ -22,11 +22,11 @@
 import pytest
 from apprise import NotifyFormat, NotifyType
 
-from airflow.operators.empty import EmptyOperator
 from airflow.providers.apprise.notifications.apprise import (
     AppriseNotifier,
     send_apprise_notification,
 )
+from airflow.providers.standard.operators.empty import EmptyOperator
 
 pytestmark = pytest.mark.db_test
 

diff --git a/providers/atlassian/jira/tests/provider_tests/atlassian/jira/notifications/test_jira.py b/providers/atlassian/jira/tests/provider_tests/atlassian/jira/notifications/test_jira.py
@@ -21,9 +21,9 @@
 
 import pytest
 
-from airflow.operators.empty import EmptyOperator
 from airflow.providers.atlassian.jira.hooks.jira import JiraHook
 from airflow.providers.atlassian.jira.notifications.jira import JiraNotifier, send_jira_notification
+from airflow.providers.standard.operators.empty import EmptyOperator
 
 pytestmark = pytest.mark.db_test
 

@@ -21,8 +21,8 @@
 
 import airflow.models.xcom
 from airflow.models.xcom import BaseXCom, resolve_xcom_backend
-from airflow.operators.empty import EmptyOperator
 from airflow.providers.common.io.xcom.backend import XComObjectStorageBackend
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.utils import timezone
 from airflow.utils.xcom import XCOM_RETURN_KEY
 

diff --git a/providers/common/sql/tests/provider_tests/common/sql/operators/test_sql.py b/providers/common/sql/tests/provider_tests/common/sql/operators/test_sql.py
@@ -27,7 +27,6 @@
 from airflow import DAG
 from airflow.exceptions import AirflowException, AirflowProviderDeprecationWarning
 from airflow.models import Connection, DagRun, TaskInstance as TI, XCom
-from airflow.operators.empty import EmptyOperator
 from airflow.providers.common.sql.hooks.sql import fetch_all_handler
 from airflow.providers.common.sql.operators.sql import (
     BaseSQLOperator,
@@ -41,6 +40,7 @@
     SQLValueCheckOperator,
 )
 from airflow.providers.postgres.hooks.postgres import PostgresHook
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.utils import timezone
 from airflow.utils.session import create_session
 from airflow.utils.state import State

@@ -19,13 +19,13 @@
 from datetime import datetime
 
 from airflow.models import DAG
-from airflow.operators.empty import EmptyOperator
 from airflow.providers.dbt.cloud.operators.dbt import (
     DbtCloudGetJobRunArtifactOperator,
     DbtCloudListJobsOperator,
     DbtCloudRunJobOperator,
 )
 from airflow.providers.dbt.cloud.sensors.dbt import DbtCloudJobRunSensor
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.utils.edgemodifier import Label
 
 from tests_common.test_utils.system_tests import get_test_env_id

diff --git a/providers/edge/src/airflow/providers/edge/example_dags/integration_test.py b/providers/edge/src/airflow/providers/edge/example_dags/integration_test.py
@@ -31,8 +31,8 @@
 from airflow.hooks.base import BaseHook
 from airflow.models.dag import DAG
 from airflow.models.variable import Variable
-from airflow.operators.empty import EmptyOperator
 from airflow.providers.common.compat.standard.operators import PythonOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.sdk import Param
 from airflow.utils.trigger_rule import TriggerRule
 

diff --git a/providers/edge/src/airflow/providers/edge/example_dags/win_test.py b/providers/edge/src/airflow/providers/edge/example_dags/win_test.py
@@ -38,7 +38,7 @@
 from airflow.models import BaseOperator
 from airflow.models.dag import DAG
 from airflow.models.variable import Variable
-from airflow.operators.empty import EmptyOperator
+from airflow.providers.standard.operators.empty import EmptyOperator
 from airflow.sdk import Param
 from airflow.utils.operator_helpers import context_to_airflow_vars
 from airflow.utils.trigger_rule import TriggerRule