The cloud-native orchestrator for the whole development lifecycle, with integrated lineage and observability.

dagster

Is there a way to configure `execute_pipeline_iterator` to send logs to the event stream?

we do this at the graphql layer with a relatively intricate interaction with gevent and graphql subscriptions

ah ok, thanks. I wanted to bubble certain events (pipeline init/start/failure) and logs up to another application as they come in. I think I'll just write a custom logger

instance=DagsterInstance.get()

Might be what you are looking for, depends on what exactly you mean 