mirror of https://github.com/abinit/abipy.git
Add check on deadlocked flows
This commit is contained in:
parent
6b3610aa60
commit
eec2583bbf
|
@ -164,6 +164,14 @@ def treat_flow(flow, options):
|
|||
print("Number of tasks launched %d" % nlaunch)
|
||||
flow.show_status()
|
||||
|
||||
if nlauch == 0:
|
||||
deadlocked, runnables, running = flow.detectdeadlocked_runnables_running()
|
||||
print("deadlocked:", deadlocked)
|
||||
print("runnables:", runnables)
|
||||
print("running:", running)
|
||||
if deadlocked and not (runnables or running):
|
||||
print("*** Flow is deadlocked ***")
|
||||
|
||||
elif options.command == "tail":
|
||||
paths = [t.output_file.path for t in flow.iflat_tasks(status="Running")]
|
||||
if not paths:
|
||||
|
|
|
@ -1,7 +1,9 @@
|
|||
machine:
|
||||
python:
|
||||
version: 2.7.8
|
||||
dependencies:
|
||||
dependenciees:
|
||||
only:
|
||||
- master # list of branches to build
|
||||
ovyerride:
|
||||
- easy_install -U setuptools
|
||||
- pip install distribute --upgrade
|
||||
|
|
Loading…
Reference in New Issue