use newly setup log sink to communicate logs from child processes to parent.
Details
Details
- Reviewers
max - Commits
- R1:fb384ad3b262: [log sink] multiprocess executor
execute sleepy pipeline with multi proc can see info logs in dagit.
Diff Detail
Diff Detail
- Repository
- R1 dagster
- Branch
- mplog (branched from master)
- Lint
Lint OK - Unit
No Unit Test Coverage
Event Timeline
python_modules/dagster/dagster/core/engine/engine_multiprocess.py | ||
---|---|---|
18 | i'm not thrilled by adding more parameters to this |