Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Pass events from the Everest run model #9001

Open
oyvindeide opened this issue Oct 21, 2024 · 2 comments · May be fixed by #9691
Open

Pass events from the Everest run model #9001

oyvindeide opened this issue Oct 21, 2024 · 2 comments · May be fixed by #9691
Assignees
@oyvindeide

Comments

@oyvindeide
Copy link
Collaborator

oyvindeide commented Oct 21, 2024 •
edited
Loading

Once we start using the ensemble evaluator in ert, we should create an events end point, something along the lines of:

ert/src/ert/experiment_server/main.py

Lines 66 to 78 in d707aab

@app.websocket("/experiments/{experiment_id}/events")
async def websocket_endpoint(websocket: WebSocket, experiment_id: str):
if experiment_id not in experiments:
return
subscriber_id = str(uuid.uuid4())
await websocket.accept()
task = experiments[experiment_id]
while True:
event = await task.get_event(subscriber_id=subscriber_id)
if isinstance(event, EndTaskEvent):
break
await websocket.send_json(event)
await asyncio.sleep(0.1)

from: https://github.com/equinor/ert/tree/experiment-server
@oyvindeide oyvindeide moved this to Todo in SCOUT Oct 21, 2024
@frode-aarstad frode-aarstad moved this from In Progress to Todo in SCOUT Oct 30, 2024
@DanSava DanSava self-assigned this Nov 20, 2024
@DanSava DanSava moved this from Todo to In Progress in SCOUT Nov 20, 2024
@DanSava DanSava removed their assignment Nov 22, 2024
@oyvindeide
Copy link
Collaborator Author

Blocked by: #8754

@oyvindeide
Copy link
Collaborator Author

This is no longer blocked, the events are currently being generated and put on the queue:

ert/src/ert/run_models/base_run_model.py

Line 220 in 05b33a5

self._status_queue.put(event)
, we now need to forward them and replace the monitoring code which reads the files on disk. In the first iteration we can replace only the status from the forward model, reading from seba snapshot will be a different issue.

@oyvindeide oyvindeide moved this from Todo to In Progress in SCOUT Jan 7, 2025
@oyvindeide oyvindeide self-assigned this Jan 7, 2025
@oyvindeide oyvindeide linked a pull request Jan 9, 2025 that will close this issue
Open
9 tasks
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@oyvindeide oyvindeide

Labels
None yet
Projects
SCOUT
Status: In Progress
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

Create end point for events oyvindeide/ert
4 participants
@DanSava @frode-aarstad @eivindjahren @oyvindeide