<filename>packages/watchmen-pipeline-surface/src/watchmen_pipeline_surface/connectors/__init__.py
from .kafka import init_kafka, KafkaSettings
from .rabbitmq import init_rabbitmq, RabbitmqSettings

<filename>packages/watchmen-pipeline-surface/src/watchmen_pipeline_surface/connectors/__init__.py
from .kafka import init_kafka, KafkaSettings
from .rabbitmq import init_rabbitmq, RabbitmqSettings
