change to custom_x

andtheysay · Aug 16, 2024 · 8a98558 · 8a98558
1 parent a8c5388
commit 8a98558
Show file tree

Hide file tree

Showing 7 changed files with 5 additions and 5 deletions.
diff --git a/src/airflow_pulsar_plugin/__init__.py b/src/airflow_pulsar_plugin/__init__.py
@@ -1,7 +1,7 @@
 from airflow.plugins_manager import AirflowPlugin
-from airflow_pulsar_plugin.hooks.pulsar_hook import PulsarHook
-from airflow_pulsar_plugin.operators.pulsar_operator import PulsarOperator
-from airflow_pulsar_plugin.sensors.pulsar_sensor import PulsarSensor
+from custom_hooks.pulsar_hook import PulsarHook
+from custom_operators.pulsar_operator import PulsarOperator
+from custom_sensors.pulsar_sensor import PulsarSensor
 
 class AirflowPulsarPlugin(AirflowPlugin):
     name = "pulsar_plugin"

diff --git a/src/airflow_pulsar_plugin/hooks/__init__.py → ...ow_pulsar_plugin/custom_hooks/__init__.py b/src/airflow_pulsar_plugin/hooks/__init__.py → ...ow_pulsar_plugin/custom_hooks/__init__.py
diff --git a/...irflow_pulsar_plugin/hooks/pulsar_hook.py → ...pulsar_plugin/custom_hooks/pulsar_hook.py b/...irflow_pulsar_plugin/hooks/pulsar_hook.py → ...pulsar_plugin/custom_hooks/pulsar_hook.py
diff --git a/...rflow_pulsar_plugin/operators/__init__.py → ...ulsar_plugin/custom_operators/__init__.py b/...rflow_pulsar_plugin/operators/__init__.py → ...ulsar_plugin/custom_operators/__init__.py
diff --git a/...ulsar_plugin/operators/pulsar_operator.py → ...lugin/custom_operators/pulsar_operator.py b/...ulsar_plugin/operators/pulsar_operator.py → ...lugin/custom_operators/pulsar_operator.py
@@ -1,6 +1,6 @@
 from airflow.utils.decorators import apply_defaults
 from airflow.models import BaseOperator
-from hooks.pulsar_hook import PulsarHook
+from custom_hooks.pulsar_hook import PulsarHook
 
 class PulsarOperator(BaseOperator):
     @apply_defaults

diff --git a/...airflow_pulsar_plugin/sensors/__init__.py → ..._pulsar_plugin/custom_sensors/__init__.py b/...airflow_pulsar_plugin/sensors/__init__.py → ..._pulsar_plugin/custom_sensors/__init__.py
diff --git a/...ow_pulsar_plugin/sensors/pulsar_sensor.py → ...ar_plugin/custom_sensors/pulsar_sensor.py b/...ow_pulsar_plugin/sensors/pulsar_sensor.py → ...ar_plugin/custom_sensors/pulsar_sensor.py
@@ -1,6 +1,6 @@
 from airflow.sensors.base import BaseSensorOperator
 from airflow.utils.decorators import apply_defaults
-from hooks.pulsar_hook import PulsarHook
+from custom_hooks.pulsar_hook import PulsarHook
 
 class PulsarSensor(BaseSensorOperator):
     @apply_defaults