diff --git a/frappe/tests/test_background_jobs.py b/frappe/tests/test_background_jobs.py
index 5b66183333..88783f14f1 100644
--- a/frappe/tests/test_background_jobs.py
+++ b/frappe/tests/test_background_jobs.py
@@ -5,24 +5,26 @@ from rq import Queue
 import frappe
 from frappe.core.page.background_jobs.background_jobs import remove_failed_jobs
 from frappe.utils.background_jobs import get_redis_conn
+import time
 
 
 class TestBackgroundJobs(unittest.TestCase):
 	def test_remove_failed_jobs(self):
-		frappe.enqueue(method="frappe.tests.test_background_jobs.fail_function")
-
+		frappe.enqueue(method="frappe.tests.test_background_jobs.fail_function", queue="short")
+		# wait for enqueued job to execute
+		time.sleep(2)
 		conn = get_redis_conn()
 		queues = Queue.all(conn)
 
 		for queue in queues:
-			if queue.name == "default":
+			if queue.name == "short":
 				fail_registry = queue.failed_job_registry
 				self.assertGreater(fail_registry.count, 0)
 
 		remove_failed_jobs()
 
 		for queue in queues:
-			if queue.name == "default":
+			if queue.name == "short":
 				fail_registry = queue.failed_job_registry
 				self.assertEqual(fail_registry.count, 0)