From e7a3e8a19e9660c3964f02f933164edbea66bf7d Mon Sep 17 00:00:00 2001
From: Chenxiong Qi <cqi@redhat.com>
Date: Wed, 4 Dec 2019 15:50:15 +0800
Subject: [PATCH] Schedule event handler to queue from internal

Signed-off-by: Chenxiong Qi <cqi@redhat.com>
---
 conf/config.py                           | 3 +++
 module_build_service/scheduler/events.py | 2 +-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/conf/config.py b/conf/config.py
index 4510fbc2..ade800ed 100644
--- a/conf/config.py
+++ b/conf/config.py
@@ -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
diff --git a/module_build_service/scheduler/events.py b/module_build_service/scheduler/events.py
index 69cada17..d1843fe7 100644
--- a/module_build_service/scheduler/events.py
+++ b/module_build_service/scheduler/events.py
@@ -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):
         """