Skip to content

Commit

Permalink
Log pending time for a job
Browse files Browse the repository at this point in the history
  • Loading branch information
berland committed Feb 4, 2025
1 parent d8467c7 commit 0dc2a57
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions src/ert/scheduler/job.py
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand All @@ -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:
Expand Down

0 comments on commit 0dc2a57

Please sign in to comment.