diff --git a/kale/publisher.py b/kale/publisher.py index 570d76f..32687f2 100644 --- a/kale/publisher.py +++ b/kale/publisher.py @@ -57,7 +57,7 @@ def publish(self, task_class, task_id, payload, sqs_queue.send_message( MessageBody=kale_msg.encode(), - DelaySeconds=delay_sec or 1 + DelaySeconds=delay_sec or 0 ) logger.debug('Published task. Task id: %s; Task name: %s' % (