Hi, I am using the execute_pipeline API. I would l...
# announcements
j
Hi, I am using the execute_pipeline API. I would like to update my UI with the real time status using the events
dagster.core.storage.event_log
. I see there is a SQLite-backed event log storage, but I need a websocket probably for real time updates. Is that how it is done on the dagit UI?
d
hi jaikant - dagit does this by using a graphql subscription with websockets - there's a field on the dagster-graphql API called pipelineRunLogs that a client can use to receive updates as the events for a given run stream in.
(oh, I should also mention that that subscription is implemented by calling the
watch
method on the event log storage class that you mentioned)
j
@daniel wow! Thanks so much for this. You guys are amazing 👌