Natalie Novitsky
01/31/2022, 8:08 PMMatt Millican
09/23/2022, 2:33 PMMultiprocessExecutor
doesn’t make it easy to transmit context from the pipeline-orchestrating parent process to the step-running child processes at execution time.
Looking at the ddtrace docs for cross-process tracing and comparing with the process boundary for the child_process_executor
, it seems like we could satisfy this use case pretty easily if Dagster added support for “hooks” at this process boundary—one in the pipeline execution/parent process to extract context and pass it through the args
to Process
, and one in the step execution/child process to extract that context and install it before the step runs.
Would it be a reasonable ask for Dagster to build in this support? Or, as Natalie suggested, would it be reasonable to add support for resources that are instantiated once for the pipeline and are in some way shared between child processes, rather than instantiated once per child?
Thanks!