Skip to content

Commit d58d625

Browse files
committed
Revert unecessary code
1 parent 1a2f2c8 commit d58d625

File tree

3 files changed

+3
-14
lines changed

3 files changed

+3
-14
lines changed

src/ert/scheduler/event.py

-2
Original file line numberDiff line numberDiff line change
@@ -7,14 +7,12 @@
77
@dataclass
88
class StartedEvent:
99
iens: int
10-
exec_hosts: str = ""
1110

1211

1312
@dataclass
1413
class FinishedEvent:
1514
iens: int
1615
returncode: int
17-
exec_hosts: str = ""
1816

1917

2018
Event = Union[StartedEvent, FinishedEvent]

src/ert/scheduler/lsf_driver.py

+2-6
Original file line numberDiff line numberDiff line change
@@ -503,15 +503,11 @@ async def _process_job_update(self, job_id: str, new_state: AnyJob) -> None:
503503
event: Optional[Event] = None
504504
if isinstance(new_state, RunningJob):
505505
logger.debug(f"Realization {iens} is running")
506-
event = StartedEvent(iens=iens, exec_hosts=self._jobs[job_id].exec_hosts)
506+
event = StartedEvent(iens=iens)
507507
elif isinstance(new_state, FinishedJobFailure):
508508
logger.info(f"Realization {iens} (LSF-id: {self._iens2jobid[iens]}) failed")
509509
exit_code = await self._get_exit_code(job_id)
510-
event = FinishedEvent(
511-
iens=iens,
512-
returncode=exit_code,
513-
exec_hosts=self._jobs[job_id].exec_hosts,
514-
)
510+
event = FinishedEvent(iens=iens, returncode=exit_code)
515511
elif isinstance(new_state, FinishedJobSuccess):
516512
logger.info(
517513
f"Realization {iens} (LSF-id: {self._iens2jobid[iens]}) succeeded"

src/ert/scheduler/scheduler.py

+1-6
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@
2828
from ert.constant_filenames import CERT_FILE
2929

3030
from .driver import Driver
31-
from .event import FinishedEvent, StartedEvent
31+
from .event import FinishedEvent
3232
from .job import Job, JobState
3333

3434
if TYPE_CHECKING:
@@ -308,11 +308,6 @@ async def _process_event_queue(self) -> None:
308308
# Any event implies the job has at least started
309309
job.started.set()
310310

311-
if isinstance(event, (StartedEvent, FinishedEvent)) and event.exec_hosts:
312-
logger.info(
313-
f"Realization {event.iens} was executed on host: {event.exec_hosts}"
314-
)
315-
316311
if (
317312
isinstance(event, FinishedEvent)
318313
and not self._cancelled

0 commit comments

Comments
 (0)