From 0dc2a57fecc9c5f80ee58ae140ee38cabb6ce30d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?H=C3=A5vard=20Berland?= <havb@equinor.com>
Date: Mon, 3 Feb 2025 15:21:27 +0100
Subject: [PATCH] Log pending time for a job

---
 src/ert/scheduler/job.py | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/src/ert/scheduler/job.py b/src/ert/scheduler/job.py
index bc96c8f69b5..f2ed683d1f3 100644
--- a/src/ert/scheduler/job.py
+++ b/src/ert/scheduler/job.py
@@ -109,6 +109,7 @@ async def _submit_and_run_once(self, sem: asyncio.BoundedSemaphore) -> None:
             if self._scheduler.submit_sleep_state:
                 await self._scheduler.submit_sleep_state.sleep_until_we_can_submit()
             await self._send(JobState.SUBMITTING)
+            submit_time = time.time()
             try:
                 await self.driver.submit(
                     self.real.iens,
@@ -128,6 +129,12 @@ async def _submit_and_run_once(self, sem: asyncio.BoundedSemaphore) -> None:
             await self._send(JobState.PENDING)
             await self.started.wait()
             self._start_time = time.time()
+            pending_time = self._start_time - submit_time
+            logger.info(
+                f"Pending time for realization {self.iens} "
+                f"was {pending_time:.2f} seconds "
+                f"(num_cpu={self.real.num_cpu} realization_memory={self.real.realization_memory})"
+            )
 
             await self._send(JobState.RUNNING)
             if self.real.max_runtime is not None and self.real.max_runtime > 0: