Skip to content
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.

Sign up for GitHub

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

main loop: plugins for periodic functions #3492

Merged
merged 19 commits into from
Apr 7, 2020
Merged

main loop: plugins for periodic functions #3492

Show file tree
Hide file tree
Changes from 16 commits
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
3ddc939
main loop: health check
oliver-sanders Jan 30, 2020
06438e7
main loop: auto restart
oliver-sanders Feb 4, 2020
73a96ea
main loop: log data store
oliver-sanders Feb 4, 2020
db36f02
main loop: log memory
oliver-sanders Feb 5, 2020
b4f4a12
main loop: tidy
oliver-sanders Feb 5, 2020
eeba9dd
main loop: store timings in a deque
oliver-sanders Feb 6, 2020
b84e904
main loop: log main loop
oliver-sanders Feb 6, 2020
a57a6f1
main loop: health check - add database health check
oliver-sanders Feb 6, 2020
73d3391
health check functional tests
oliver-sanders Feb 7, 2020
62c6640
parsec: interface for extracting keys from multiple dicts
oliver-sanders Feb 17, 2020
b4b4cba
scheduler: interface for ["cylc"] config items
oliver-sanders Feb 7, 2020
436f881
main loop: re-raise CylcError as MainLoopPluginException
oliver-sanders Feb 7, 2020
d9d496e
pycodestyle
oliver-sanders Feb 18, 2020
da2f043
main loop: revert merging of db lock check with health check
oliver-sanders Mar 17, 2020
cecce72
main loop: decorator function syntax
oliver-sanders Mar 30, 2020
7e69fe0
main loop: document coroutine types
oliver-sanders Apr 6, 2020
56269f0
main loop: print available plugins on entry error
oliver-sanders Apr 7, 2020
849d22e
main loop: document plot generation
oliver-sanders Apr 7, 2020
38822a8
main loop: review feedback
oliver-sanders Apr 7, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion cylc/flow/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,8 @@
import logging


LOG = logging.getLogger('cylc') # Acceptable?
CYLC_LOG = 'cylc'
LOG = logging.getLogger(CYLC_LOG)
LOG.addHandler(logging.NullHandler()) # Start with a null handler


Expand Down
10 changes: 9 additions & 1 deletion cylc/flow/cfgspec/globalcfg.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,6 @@
# suite
'cylc': {
'UTC mode': [VDR.V_BOOLEAN],
'health check interval': [VDR.V_INTERVAL, DurationFloat(600)],
'task event mail interval': [VDR.V_INTERVAL, DurationFloat(300)],
'events': {
'handlers': [VDR.V_STRING_LIST],
Expand All @@ -67,6 +66,15 @@
'abort on inactivity': [VDR.V_BOOLEAN],
'abort on stalled': [VDR.V_BOOLEAN],
},
'main loop': {
'plugins': [VDR.V_STRING_LIST, ['health check']],
'health check': {
'interval': [VDR.V_INTERVAL, DurationFloat(600)]
},
'__MANY__': {
'interval': [VDR.V_INTERVAL]
}
}
},

# suite
Expand Down
9 changes: 8 additions & 1 deletion cylc/flow/cfgspec/suite.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -56,9 +56,13 @@
VDR.V_STRING, '', 'live', 'dummy', 'dummy-local', 'simulation'],
'force run mode': [
VDR.V_STRING, '', 'live', 'dummy', 'dummy-local', 'simulation'],
'health check interval': [VDR.V_INTERVAL],
'task event mail interval': [VDR.V_INTERVAL],
'disable automatic shutdown': [VDR.V_BOOLEAN],
'main loop': {
'__MANY__': {
'interval': [VDR.V_INTERVAL],
}
},
'simulation': {
'disable suite event handlers': [VDR.V_BOOLEAN, True],
},
Expand Down Expand Up @@ -300,6 +304,9 @@ def upg(cfg, descr):
u.obsolete(
'8.0.0',
['cylc', 'reference test', 'suite shutdown event handler'])
u.obsolete(
'8.0.0',
['cylc', 'health check interval'])
u.deprecate(
'8.0.0',
['cylc', 'abort if any task fails'],
Expand Down
Loading