diff --git a/tests/conftest.py b/tests/conftest.py
index 7dd82d16..062ebde3 100644
--- a/tests/conftest.py
+++ b/tests/conftest.py
@@ -60,6 +60,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()