diff --git a/compute_worker/compute_worker.py b/compute_worker/compute_worker.py
index 31e9a3e54..dae7bff60 100644
--- a/compute_worker/compute_worker.py
+++ b/compute_worker/compute_worker.py
@@ -1280,6 +1280,9 @@ def start(self):
                 # set logs of this kind to None, since we handled them already
                 logger.info("Program finished")
         signal.alarm(0)
+        # Ensure loop is cleaned up
+        loop.close()
+        asyncio.set_event_loop(None)
 
         if self.is_scoring:
             # Check if scoring program failed