diff --git a/routers/amqp.py b/routers/amqp.py index 5ba680d..fbbf3ab 100644 --- a/routers/amqp.py +++ b/routers/amqp.py @@ -8,8 +8,8 @@ from tc_messageBroker.rabbit_mq.event import Event from tc_messageBroker.rabbit_mq.queue import Queue from utils.credentials import load_rabbitmq_credentials -from utils.traceloop import init_tracing from utils.persist_payload import PersistPayload +from utils.traceloop import init_tracing from worker.tasks import query_data_sources from worker.utils.fire_event import job_send