<style type="text/css">
.highlight .hll
.highlight
.highlight .c
/* Comment */
.highlight .err
/* Error */
.highlight .k
/* Keyword */
.highlight .o
/* Operator */
.highlight .cm
/* Comment.Multiline */
.highlight .cp
/* Comment.Preproc */
.highlight .c1
/* Comment.Single */
.highlight .cs
/* Comment.Special */
.highlight .gd
/* Generic.Deleted */
.highlight .ge
/* Generic.Emph */
.highlight .gr
/* Generic.Error */
.highlight .gh
/* Generic.Heading */
.highlight .gi
/* Generic.Inserted */
.highlight .go
/* Generic.Output */
.highlight .gp
/* Generic.Prompt */
.highlight .gs
/* Generic.Strong */
.highlight .gu
/* Generic.Subheading */
.highlight .gt
/* Generic.Traceback */
.highlight .kc
/* Keyword.Constant */
.highlight .kd
/* Keyword.Declaration */
.highlight .kn
/* Keyword.Namespace */
.highlight .kp
/* Keyword.Pseudo */
.highlight .kr
/* Keyword.Reserved */
.highlight .kt
/* Keyword.Type */
.highlight .m
/* Literal.Number */
.highlight .s
/* Literal.String */
.highlight .na
/* Name.Attribute */
.highlight .nb
/* Name.Builtin */
.highlight .nc
/* Name.Class */
.highlight .no
/* Name.Constant */
.highlight .nd
/* Name.Decorator */
.highlight .ni
/* Name.Entity */
.highlight .ne
/* Name.Exception */
.highlight .nf
/* Name.Function */
.highlight .nl
/* Name.Label */
.highlight .nn
/* Name.Namespace */
.highlight .nt
/* Name.Tag */
.highlight .nv
/* Name.Variable */
.highlight .ow
/* Operator.Word */
.highlight .w
/* Text.Whitespace */
.highlight .mf
/* Literal.Number.Float */
.highlight .mh
/* Literal.Number.Hex */
.highlight .mi
/* Literal.Number.Integer */
.highlight .mo
/* Literal.Number.Oct */
.highlight .sb
/* Literal.String.Backtick */
.highlight .sc
/* Literal.String.Char */
.highlight .sd
/* Literal.String.Doc */
.highlight .s2
/* Literal.String.Double */
.highlight .se
/* Literal.String.Escape */
.highlight .sh
/* Literal.String.Heredoc */
.highlight .si
/* Literal.String.Interpol */
.highlight .sx
/* Literal.String.Other */
.highlight .sr
/* Literal.String.Regex */
.highlight .s1
/* Literal.String.Single */
.highlight .ss
/* Literal.String.Symbol */
.highlight .bp
/* Name.Builtin.Pseudo */
.highlight .vc
/* Name.Variable.Class */
.highlight .vg
/* Name.Variable.Global */
.highlight .vi
/* Name.Variable.Instance */
.highlight .il
/* Literal.Number.Integer.Long */
</style>
One possible solution:
#!/usr/bin/env python2.5
import os
import ecflow
defs = ecflow.Defs()
suite = defs.add_suite("operation_suite")
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/oper")
# Defines the triggers for the first cycle
cycle_triggers = "1"
for cycle in ( 0 , 12 ):
if cycle == 12 :
last_step = 240
else:
last_step = 24
fcycle_fam = suite.add_family(str(cycle))
fcycle_fam.add_variable("CYCLE",cycle)
fcycle_fam.add_variable("LAST_STEP",last_step)
if cycle_triggers != "1" :
fcycle_fam.add_trigger(cycle_triggers)
analysis_fam = fcycle_fam.add_family("analysis")
analysis_fam.add_task("get_observations")
analysis_fam.add_task("run_analysis").add_trigger("get_observations == complete")
analysis_fam.add_task("post_processing").add_trigger("run_analysis == complete")
forecast_fam = fcycle_fam.add_family("forecast")
forecast_fam.add_trigger("analysis == complete")
forecast_fam.add_task("get_input_data")
run_forecast_task = forecast_fam.add_task("run_forecast")
run_forecast_task.add_trigger("get_input_data == complete")
run_forecast_task.add_meter("step",0,last_step,last_step)
archive_fam = fcycle_fam.add_family("archive")
fam_analsis = archive_fam.add_family("analysis")
fam_analsis.add_variable("TYPE","analysis")
fam_analsis.add_variable("STEP","0")
fam_analsis.add_trigger("../analysis/run_analysis == complete")
fam_analsis.add_task("save")
for i in range(6,last_step,6):
step_fam = fam_analsis.add_family("step_" + str(i))
step_fam.add_variable("TYPE","forecast")
step_fam.add_variable("STEP",i)
step_fam.add_trigger("../forecast/run_forecast:step ge " + str(i))
step_fam.add_task("save")
# Defines the triggers for the next cycle
cycle_triggers = "./" + str(cycle) + " == complete"