Schedule event handler to queue from internal

Signed-off-by: Chenxiong Qi <cqi@redhat.com>
This commit is contained in:
Chenxiong Qi
2019-12-04 15:50:15 +08:00
committed by mprahl
parent f2b57c7d91
commit e7a3e8a19e
2 changed files with 4 additions and 1 deletions

View File

@@ -115,6 +115,9 @@ class TestConfiguration(BaseConfiguration):
STREAM_SUFFIXES = {r"^el\d+\.\d+\.\d+\.z$": 0.1}
# Ensures task.delay executes locally instead of scheduling a task to a queue.
CELERY_TASK_ALWAYS_EAGER = True
class ProdConfiguration(BaseConfiguration):
pass

View File

@@ -44,7 +44,7 @@ class Scheduler(sched.scheduler):
"""
Schedule execution of `handler` with `arguments`.
"""
self.enter(0, 0, handler, arguments)
self.enter(0, 0, handler.delay, arguments)
def run(self):
"""