diff --git a/tests/conftest.py b/tests/conftest.py
index d3f0d347..edeec6a5 100644
--- a/tests/conftest.py
+++ b/tests/conftest.py
@@ -59,6 +59,14 @@ async def reportFailed(self, *args, **kwargs):
         raise taskcluster.exceptions.TaskclusterRestFailure("foo", None, status_code=self.status)
 
 
+@pytest.fixture(scope="function")
+def event_loop(request):
+    request.param
+    loop = asyncio.new_event_loop()
+    yield loop
+    loop.close()
+
+
 @pytest.fixture(scope="function")
 def successful_queue():
     return SuccessfulQueue()