From b6411de6b2072844329eb6e15040229fbf0b2c66 Mon Sep 17 00:00:00 2001 From: Julius Unverfehrt Date: Tue, 15 Feb 2022 09:43:20 +0100 Subject: [PATCH] typo --- mini_queue/run.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/mini_queue/run.py b/mini_queue/run.py index 5694905..701791f 100644 --- a/mini_queue/run.py +++ b/mini_queue/run.py @@ -1,5 +1,6 @@ import logging import sys +from time import time import pika from retry import retry @@ -8,7 +9,7 @@ from mini_queue.utils.config import CONFIG def callback(channel, method, properties, body): logging.info(" [R] Received %r" % body) - sys.sleep(1) + time.sleep(1) response = body channel.basic_publish(exchange="", routing_key=CONFIG.rabbitmq.queues.output, body=response) channel.basic_ack(delivery_tag=method.delivery_tag)