...
#!/usr/bin/env python2.7
import os
import ecflow
defs = ecflow.Defs()
suite = defs.add_suite("data_aquisition")
suite.add_repeat( ecflow.RepeatDay(1) )
suite.add_variable("ECF_HOME", os.getenv("HOME") + "/course")
suite.add_variable("ECF_INCLUDE", os.getenv("HOME") + "/course")
suite.add_variable("ECF_FILES", os.getenv("HOME") + "/course/data")
suite.add_variable("SLEEP","2")
for city in ( "Exeter", "Toulouse", "Offenbach", "Washington", "Tokyo", "Melbourne", "Montreal" ) :
fcity = suite.add_family(city)
fcity.add_task("archive")
for obs_type in ( "observations", "fields", "images" ):
type_fam = fcity.add_family(obs_type)
if city in ("exeterExeter", "toulouseToulouse", "offenbachOffenbach"): type_fam.add_time("00:00 23:00 01:00")
if city in ("washingtonWashington") : type_fam.add_time("00:00 23:00 03:00")
if city in ("tokyoTokyo") : type_fam.add_time("12:00")
if city in ("melbourneMelbourne") : type_fam.add_day( "monday" )
if city in ("montrealMontreal") : type_fam.add_date(1, 0, 0)
type_fam.add_task("get")
type_fam.add_task("process").add_trigger("get eq complete")
type_fam.add_task("store").add_trigger("get eq complete")
...