Versions Compared

Old Version 39

changes.mady.by.user Axel Bonet

Saved on

compared with

New Version Current

changes.mady.by.user Unknown User (ma0)

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.


Horizontal Navigation Bar


Button Group

Button Hyperlink
titlePrevious
typestandard
urlhttps://softwareconfluence.ecmwf.int/wiki/display/ECFLOW/Add+another+taskTrigger
Button Hyperlink
titleUp
typestandard
urlhttps://softwareconfluence.ecmwf.int/wiki/display/ECFLOW/Going+Further
Button Hyperlink
titleNext
typestandard
urlhttps://softwareconfluence.ecmwf.int/wiki/display/ECFLOW/Families

 

Add+a+complete



Sometimes waiting for the completion of a task is not good enough.
If a task is producing several results, another task may start as
soon as the first results are ready.
For that, ecFlow introduces the concept of event‘s.
An event is a message that a task will report to ecflow_server while it is running.

Events have names and a task can set several of them.


Ecf Script

We will create new tasks (t3, t4) that will be triggered by the events emitted in task t2.
Create the ecf script for t3 and t4 by copying t1.
To notify ecflow_server, the task (t2 in the example below)
must call ecflow_client –event which is one of the child command‘s


Code Block
languagebash
titleAmend $HOME/course/test/f1/t2.ecf

 

code
%include <head.h>
echo "I will now sleep for %SLEEP% seconds"
sleep %SLEEP%
ecflow_client --event =a       # Set the first event
sleep %SLEEP%                 # Sleep a bit more
ecflow_client --event =b       # Set the second event
sleep %SLEEP%                 # A last nap...
%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
     task t2
         trigger t1 eq complete
         event a
         event b
     task t3
         trigger t2:a
     task t4
         trigger t2:b
   endfamily
endsuite
 

Python

#!/usr/bin/env python2.7 

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

import
from ecflow import Defs,Suite,Family,Task,Edit,Trigger,Event

def create_family_f1():
    
f1
return 
= ecflow.
Family("f1"
)
,
    
f1.add_variable("SLEEP", 20)

            Edit(SLEEP=20),
               
f1.add_task
 Task("t1"),
      


    


    
t2
 
=
 
f1.add_task
Task("t2"
)
,
                


    
t2.add_trigger
Trigger("t1 
eq
== complete")
 

,
                    
t2.add_event
Event("a"),
    
t2.add_event
                Event("b")),
            


    
f1.add_task
Task("t3"
).add_trigger
,
                    Trigger("t2:a")),
  


              
f1.add_task
Task("t4"
).add_trigger
,
                    Trigger("t2:b")))
        


    
return
 
f1




print
 
("Creating suite definition"
   
defs = ecflow.Defs(
)

suite
home = 
defs.add_suite("test")
suite.add_variable("ECF_INCLUDE", 
os.path.join(os.getenv("HOME"), 
+ 
"
/
course")

suite.add_variable("ECF_HOME",

defs = Defs( 
        Suite("test",
          
os.getenv("HOME") + "/course")

suite.add_family(
  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. Update test.def or test.py
  2. Edit t2.ecf to call ecflow_client –event.
  3. Copy t1.ecf to t3.ecf and t4.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 selectingt2/t3 and clicking on the icon triggersImage RemovedSee the triggers by selecting t2 and click on Dependenciestrigger tab
      
 Horizontal Navigation Bar

 Button Group
 Button Hyperlink
titlePrevious
typestandard
urlhttps://softwareconfluence.ecmwf.int/wiki/display/ECFLOW/Add+another+taskTrigger
 Button Hyperlink
titleUp
typestandard
urlhttps://softwareconfluence.ecmwf.int/wiki/display/ECFLOW/Going+Further
 Button Hyperlink
titleNext
typestandard
urlhttps://softwareconfluence.ecmwf.int/wiki/display/ECFLOW/FamiliesAdd+a+complete