Hi I am using the execute pipeline API I would like to updat

Question

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

daniel · Answer

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

daniel · Answer

the subscription field is defined here if you re interested <https sourcegraph com github com dagster io dagster blob js modules dagit src graphql schema graphql L1057>

daniel · Answer

oh I should also mention that that subscription is implemented by calling the `watch` method on the event log storage class that you mentioned

Jai Kumaran · Answer

< daniel> wow Thanks so much for this You guys are amazing ok hand