[Core] Log monitor multidriver#8953
Conversation
…command-format
…and-runner-interactivity
…idriver-logging
|
Test FAILed. |
| json.dumps({ | ||
| "ip": self.ip, | ||
| "pid": file_info.worker_pid, | ||
| "job": file_info.job_id, |
There was a problem hiding this comment.
Where is this actually checked? I don't see the code in this PR.
| ray.get(f.remote()) | ||
|
|
||
|
|
||
| def test_multi_driver_logging(ray_start_regular): |
There was a problem hiding this comment.
Did you check that this test fails before filtering by job id?
|
Test FAILed. |
|
Test PASSed. |
|
Test PASSed. |
|
Test PASSed. |
|
Test PASSed. |
Why are these changes needed?
Note: This is based off of #8885, not master.
This PR ensures that stdout/err for tasks are directed at the proper drivers and not broadcasted to all drivers.
Related issue number
Closes #4029
Checks
scripts/format.shto lint the changes in this PR.