Skip to content

Commit

Permalink
Remove unused function
Browse files Browse the repository at this point in the history
  • Loading branch information
oyvindeide committed Nov 1, 2024
1 parent 923e570 commit 413b41e
Showing 1 changed file with 0 additions and 61 deletions.
61 changes: 0 additions & 61 deletions src/everest/detached/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
import re
import time
import traceback
from datetime import datetime
from enum import Enum
from pathlib import Path
from typing import List, Literal, Mapping, Optional, Tuple
Expand All @@ -21,7 +20,6 @@
from ert.scheduler.event import StartedEvent
from everest.config import EverestConfig
from everest.config_keys import ConfigKeys as CK
from everest.simulator import JOB_FAILURE, JOB_SUCCESS, Status
from everest.strings import (
EVEREST,
EVEREST_SERVER_CONFIG,
Expand Down Expand Up @@ -165,65 +163,6 @@ def wait_for_server(config: EverestConfig, timeout: int) -> None:
raise RuntimeError("Failed to start server within configured timeout.")


def get_sim_status(config: EverestConfig):
"""Retrieve a seba database snapshot and return a list of simulation
information objects for each of the available batches in the database
Example: [{progress: [[{'start_time': u'Thu, 16 May 2019 16:53:20 UTC',
'end_time': u'Thu, 16 May 2019 16:53:20 UTC',
'status': JOB_SUCCESS}]],
'batch_number': 0,
'event': 'update'}, ..]
"""

seba_snapshot = SebaSnapshot(config.optimization_output_dir)
snapshot = seba_snapshot.get_snapshot()

def timestamp2str(timestamp):
if timestamp:
return "{} UTC".format(
datetime.fromtimestamp(timestamp).strftime("%a, %d %b %Y %H:%M:%S %Z")
)
else:
return None

sim_progress: dict = {}
for sim in snapshot.simulation_data:
sim_metadata = {
"start_time": timestamp2str(sim.start_time),
"end_time": timestamp2str(sim.end_time),
"realization": sim.realization,
"simulation": sim.simulation,
"status": JOB_SUCCESS if sim.success else JOB_FAILURE,
}
if sim.batch in sim_progress:
sim_progress[sim.batch]["progress"].append([sim_metadata])
else:
sim_progress[sim.batch] = {
"progress": [[sim_metadata]],
"batch_number": sim.batch,
"event": "update",
}
for status in sim_progress.values():
fm_runs = len(status["progress"])
failed = sum(
fm_run[0]["status"] == JOB_FAILURE for fm_run in status["progress"]
)
status.update(
{
"status": Status(
waiting=0,
pending=0,
running=0,
failed=failed,
complete=fm_runs - failed,
)
}
)

return list(sim_progress.values())


def get_opt_status(output_folder):
"""Retrieve a seba database snapshot and return a dictionary with
optimization information."""
Expand Down

0 comments on commit 413b41e

Please sign in to comment.