Skip to content
Snippets Groups Projects

Draft: Resolve "Validated data : listen to integration queue in order to process validated data"

+ 1
1
@@ -8,8 +8,8 @@ from celery.exceptions import Retry, WorkerLostError
from celery.schedules import crontab
from celery.utils.log import get_task_logger
from celery.worker.request import Request as _Request
from kombu import Channel as KombuChannel
from kombu import Consumer, Exchange, Message, Queue
from kombu.transport.virtual import Channel as KombuChannel
from obspy import UTCDateTime, read
from obspy.clients.fdsn.client import (
FDSNBadRequestException,
Loading