-
Notifications
You must be signed in to change notification settings - Fork 94
Poll comms: always process standard outputs on poll #6599
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: master
Are you sure you want to change the base?
Conversation
5b00e12
to
dd6c0c1
Compare
152e791
to
ab8166d
Compare
In case a task went through >1 state change since the last poll, always process the all outputs gleaned from the job poll info
cylc/flow/job_runner_mgr.py
Outdated
from typing_extensions import Literal | ||
|
||
|
||
@dataclass |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
If switching to dataclass please turn slots on to match the original implementation (or revert to plain class).
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ok, unfortunately slots cannot be used with default values in dataclasses until Python 3.10, so I have partially reverted and left a comment
'time_submit_exit', # submit (exit) time | ||
'time_run', # run start time | ||
'time_run_exit', # run exit time | ||
'job_runner_call_no_lines', # line count in job runner call stdout |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
job_runner_call_no_lines
was unused
In case a task went through >1 state change since the last poll, always process the all outputs gleaned from the job poll info.
However this means that repeated polls will repeat the same outputs, so this PR also needs:
Also closes #6593
Check List
CONTRIBUTING.md
and added my name as a Code Contributor.setup.cfg
(andconda-environment.yml
if present).?.?.x
branch.