Page History

Ecf Script

%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

# 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

Code Block
language py title $HOME/course/test.py
import os

import

from ecflow import Defs,Suite,Family,Task,Edit,Trigger,Complete,Event,Meter def create_family_f1():

f1 =

return

ecflow.

Family("f1"

)

,

f1.add_variable("SLEEP", 20) f1.add_task("t1").add_meter

Edit(SLEEP=20), Task("t1", Meter("progress", 1, 100, 90)),

t2=f1.add_task("t2") t2.add_trigger

Task("t2", Trigger("t1

eq

== complete")

t2.add_event

, Event("a")

t2.add_event

, Event("b")),

f1.add_task

Task("t3"

).add_trigger

, Trigger("t2:a")),

t4=f1.add_task

Task("t4"

) t4.add_trigger

, Trigger("t2

eq

== complete")

t4.add_complete

, Complete("t2:b"))

,

f1.add_task

Task("t5"

).add_trigger

, Trigger("t1:progress ge 30")),

f1.add_task

Task("t6"

).add_trigger

, Trigger("t1:progress ge 60")),

f1.add_task

Task("t7"

).add_trigger

, Trigger("t1:progress ge 90")))

returnf1

print

("Creating suite definition"

)

defs

home =

ecflow.Defs() suite = defs.add_suite("test") suite.add_variable("ECF_INCLUDE",

os.path.join(os.getenv("HOME")

+

, "

/

course")

suite.add_variable("ECF_HOME", os.getenv("HOME") + "/course") suite.add_family(

defs = Defs( Suite("test", Edit(ECF_INCLUDE=home,ECF_HOME=home), create_family_f1()

)) print(defs)

defs

print

("Checking job creation: .ecf -> .job0"

) print

(defs.check_job_creation())

print "Checking trigger expressions"

print

defs.check

(

) print

"Saving definition to file 'test.def'") defs.save_as_defs("test.def")

What to do

1. Edit the definition file or python to add the modifications.
2. Edit t1.ecf to call ecflow_client –meter
3. Copy t4.ecf to t5.ecf, t6.ecf and t7.ecf
4. Replace the suite
   python: python3 test.py ; python3 client.py
   text:      ecflow_client --suspend=/test   ; ecflow_client --replace=/test  test.def
5. Observe the tasks in ecflowview.in ecflow_ui
6. See the triggers by selecting progress and clicking on the Triggers icon.
7. Move the mouse pointer over Image Removed progress icon, then with the right mouse button, choose Edit...
8. Modify the value of the meter and click on the Apply icon Image Removed

1. .