Remove unused queue.stop_jobs and rename JobQueue.stop_jobs_async -> …

…JobQueue.stop_jobs

src/ert/job_queue/queue.py

@@ -8,19 +8,9 @@
 import json
 import logging
 import ssl
-import time
 from collections import deque
 from threading import BoundedSemaphore, Semaphore
-from typing import (
-    TYPE_CHECKING,
-    Callable,
-    Dict,
-    List,
-    Optional,
-    Sequence,
-    Tuple,
-    Union,
-)
+from typing import TYPE_CHECKING, Callable, Dict, List, Optional, Sequence, Tuple, Union
 
 from cloudevents.conversion import to_json
 from cloudevents.http import CloudEvent
@@ -202,13 +192,7 @@ def max_running(self) -> int:
     def available_capacity(self) -> bool:
         return not self.stopped and self.count_running() < self.max_running()
 
-    def stop_jobs(self) -> None:
-        for job in self.job_list:
-            job.stop()
-        while self.is_active():
-            time.sleep(1)
-
-    async def stop_jobs_async(self) -> None:
+    async def stop_jobs(self) -> None:
         for job in self.job_list:
             job.stop()
         while self.is_active():
@@ -325,7 +309,7 @@ async def execute(
 
                 if self.stopped:
                     logger.debug("queue cancelled, stopping jobs...")
-                    await self.stop_jobs_async()
+                    await self.stop_jobs()
                     await self._changes_to_publish.put(CLOSE_PUBLISHER_SENTINEL)
                     return EVTYPE_ENSEMBLE_CANCELLED
 
@@ -337,7 +321,7 @@ async def execute(
                 "unexpected exception in queue",
                 exc_info=True,
             )
-            await self.stop_jobs_async()
+            await self.stop_jobs()
             logger.debug("jobs stopped, re-raising exception")
             return EVTYPE_ENSEMBLE_FAILED