Right asyncio loop syntax (following #2237)

Author: Didayolo

compute_worker/compute_worker.py

@@ -1213,21 +1213,23 @@ def start(self):
 
         logger.info("Running scoring program, and then ingestion program")
         loop = asyncio.new_event_loop()
+        asyncio.set_event_loop(loop)
         gathered_tasks = asyncio.gather(
             self._run_program_directory(program_dir, kind="program"),
             self._run_program_directory(ingestion_program_dir, kind="ingestion"),
             self.watch_detailed_results(),
-            loop=loop,
             return_exceptions=True,
         )
 
         task_results = []  # will store results/exceptions from gather
         signal.signal(signal.SIGALRM, alarm_handler)
         signal.alarm(self.execution_time_limit)
+
         try:
             # run tasks
             # keep what gather returned so we can detect async errors later
             task_results = loop.run_until_complete(gathered_tasks) or []
+
         except ExecutionTimeLimitExceeded:
             error_message = f"Execution Time Limit exceeded. Limit was {self.execution_time_limit} seconds"
             logger.error(error_message)
@@ -1261,7 +1263,10 @@ def start(self):
             # Send error through web socket to the frontend
             asyncio.run(self._send_data_through_socket(error_message))
             raise SubmissionException(error_message)
+
         finally:
+            signal.alarm(0)
+            asyncio.set_event_loop(None)
             loop.close()
             self.watch = False
             for kind, logs in self.logs.items():
@@ -1308,7 +1313,6 @@ def start(self):
 
                 # set logs of this kind to None, since we handled them already
                 logger.info("Program finished")
-        signal.alarm(0)
 
         if self.is_scoring:
             # Check if scoring program failed
@@ -1327,6 +1331,7 @@ def start(self):
                 # Raise so upstream marks failed immediately
                 raise SubmissionException("Child task failed or non-zero return code")
             self._update_status(STATUS_FINISHED)
+
         else:
             self._update_status(STATUS_SCORING)