Page History
Horizontal Navigation Bar | ||||||||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
|
Instead of being a boolean value (on/off), it can take a range of integer values.
Other tasks are then triggered when the meter reaches a certain value.
Ecf Script
We will create new tasks (t5, t6, and t7) that will be triggered
when the meter in task t1 reaches certain values.
Code Block | ||||
---|---|---|---|---|
| ||||
%include <head.h> echo "I will now sleep for %SLEEP% seconds" sleep %SLEEP% n=1 while [[ $n -le 100 ]] # Loop 100 times do sleep 1 # Wait a short time ecflow_client --meter |
=progress $n # Notify ecFlow (( n = $n + 1 )) done %include <tail.h> |
Text
Code Block |
---|
# Definition of the suite test.
suite test
edit ECF_INCLUDE "$HOME/course" # replace '$HOME' with the path to your home directory
edit ECF_HOME "$HOME/course"
family f1
edit SLEEP 20
task t1
meter progress 1 100 90
task t2
trigger t1 eq complete
event a
event b
task t3
trigger t2:a
task t4
trigger t2 eq complete
complete t2:b
task t5
trigger t1:progress ge 30
task t6
trigger t1:progress ge 60
task t7
trigger t1:progress ge 90
endfamily
endsuite |
Python
#!/usr/bin/env python2.7Code Block | ||||
---|---|---|---|---|
| ||||
import os |
from ecflow import Defs,Suite,Family,Task,Edit,Trigger,Complete,Event,Meter def create_family_f1(): |
return |
Family("f1" |
, |
Edit(SLEEP=20), Task("t1", Meter("progress", 1, 100, 90)), |
|
|
|
|
|
Task("t2", Trigger("t1 |
== complete") |
, Event("a") |
, Event("b")), |
|
Task("t3" |
, Trigger("t2:a")), |
|
|
|
|
Task("t4" |
, Trigger("t2 |
== complete") |
, Complete("t2:b")) |
, |
|
Task("t5" |
, Trigger("t1:progress ge 30")), |
Task("t6" |
, Trigger("t1:progress ge 60")), |
Task("t7" |
, Trigger("t1:progress ge 90"))) |
|
|
("Creating suite definition" |
) |
home = |
os.path.join(os.getenv("HOME") |
, " |
course") |
defs = Defs( Suite("test", Edit(ECF_INCLUDE=home,ECF_HOME=home), create_family_f1() |
)) print(defs) |
("Checking job creation: .ecf -> .job0" |
(defs.check_job_creation()) |
( |
"Saving definition to file 'test.def'") defs.save_as_defs("test.def") |
What to do
:- Edit the definition file or python to add the modifications.
- Edit t1.ecf to call ecflow_client –meter
- Copy t4.ecf to t5.ecf, t6.ecf and t7.ecf
- Replace the suite
python: python3 test.py ; python3 client.py
text: ecflow_client --suspend=/test ; ecflow_client --replace=/test test.def - Observe the tasks in ecflowview.in ecflow_ui
- See the triggers by selecting progress and clicking on the Triggers icon.
- Move the mouse pointer over progress icon, then with the right mouse button, choose Edit...
- Modify the value of the meter and click on the Apply icon
...
- .
Horizontal Navigation Bar | ||||||||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
|