From 8a985583a1b46ef94fa3ef1bb0fc9a4507a7ac9a Mon Sep 17 00:00:00 2001 From: andtheysay Date: Fri, 16 Aug 2024 14:05:58 -0500 Subject: [PATCH] change to custom_x --- src/airflow_pulsar_plugin/__init__.py | 6 +++--- .../{hooks => custom_hooks}/__init__.py | 0 .../{hooks => custom_hooks}/pulsar_hook.py | 0 .../{operators => custom_operators}/__init__.py | 0 .../{operators => custom_operators}/pulsar_operator.py | 2 +- .../{sensors => custom_sensors}/__init__.py | 0 .../{sensors => custom_sensors}/pulsar_sensor.py | 2 +- 7 files changed, 5 insertions(+), 5 deletions(-) rename src/airflow_pulsar_plugin/{hooks => custom_hooks}/__init__.py (100%) rename src/airflow_pulsar_plugin/{hooks => custom_hooks}/pulsar_hook.py (100%) rename src/airflow_pulsar_plugin/{operators => custom_operators}/__init__.py (100%) rename src/airflow_pulsar_plugin/{operators => custom_operators}/pulsar_operator.py (93%) rename src/airflow_pulsar_plugin/{sensors => custom_sensors}/__init__.py (100%) rename src/airflow_pulsar_plugin/{sensors => custom_sensors}/pulsar_sensor.py (96%) diff --git a/src/airflow_pulsar_plugin/__init__.py b/src/airflow_pulsar_plugin/__init__.py index 83317cc..4cd222f 100644 --- 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 b/src/airflow_pulsar_plugin/custom_hooks/__init__.py similarity index 100% rename from src/airflow_pulsar_plugin/hooks/__init__.py rename to src/airflow_pulsar_plugin/custom_hooks/__init__.py diff --git a/src/airflow_pulsar_plugin/hooks/pulsar_hook.py b/src/airflow_pulsar_plugin/custom_hooks/pulsar_hook.py similarity index 100% rename from src/airflow_pulsar_plugin/hooks/pulsar_hook.py rename to src/airflow_pulsar_plugin/custom_hooks/pulsar_hook.py diff --git a/src/airflow_pulsar_plugin/operators/__init__.py b/src/airflow_pulsar_plugin/custom_operators/__init__.py similarity index 100% rename from src/airflow_pulsar_plugin/operators/__init__.py rename to src/airflow_pulsar_plugin/custom_operators/__init__.py diff --git a/src/airflow_pulsar_plugin/operators/pulsar_operator.py b/src/airflow_pulsar_plugin/custom_operators/pulsar_operator.py similarity index 93% rename from src/airflow_pulsar_plugin/operators/pulsar_operator.py rename to src/airflow_pulsar_plugin/custom_operators/pulsar_operator.py index 762fe07..ffd3f19 100644 --- a/src/airflow_pulsar_plugin/operators/pulsar_operator.py +++ b/src/airflow_pulsar_plugin/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/src/airflow_pulsar_plugin/sensors/__init__.py b/src/airflow_pulsar_plugin/custom_sensors/__init__.py similarity index 100% rename from src/airflow_pulsar_plugin/sensors/__init__.py rename to src/airflow_pulsar_plugin/custom_sensors/__init__.py diff --git a/src/airflow_pulsar_plugin/sensors/pulsar_sensor.py b/src/airflow_pulsar_plugin/custom_sensors/pulsar_sensor.py similarity index 96% rename from src/airflow_pulsar_plugin/sensors/pulsar_sensor.py rename to src/airflow_pulsar_plugin/custom_sensors/pulsar_sensor.py index b149a9a..9a64658 100644 --- a/src/airflow_pulsar_plugin/sensors/pulsar_sensor.py +++ b/src/airflow_pulsar_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