Data Notifier example WIP

flow.cylc

#!Jinja2

{% if MEMBERS is not defined %}
{% set MEMBERS = 4 %}
{% endif %}

[scheduler]
    UTC mode = true
    allow implicit tasks = True
[scheduling]
    initial cycle point = 20100201T00Z
    final cycle point = 20100301T00Z
    [[graph]]
        R1 = "local_setup => remote_setup => pre_step"

        R1/20100301T0000Z = """
        {% for j in range(MEMBERS) %}
        {% if j not in (2, 8) %}
        pre_step => fc{{ j }} => post
        post[-P1M]:submitted => pre_step
        {% endif %}
        {% endfor %}
        """

        P1M!20100301T0000Z = """
        pre_step => MEMBERS:succeed-all => post
        post[-P1M]:submitted => pre_step
        """
[runtime]
    [[root]]
        script = "sleep 5"
    [[MEMBERS]]
        script = "run_member.sh"
        [[[environment]]]
            FDB_CONFIG = "bla"
    {% for i in range(0, MEMBERS) %}
    [[fc{{ i }}]]
        inherit = MEMBERS
    {% endfor %}
#    [[foo]]
#        script = """
#            cylc__job__wait_cylc_message_started
#            cylc message -- "${CYLC_WORKFLOW_ID}" "${CYLC_TASK_JOB}" "the cheese is ready"
#        """
#        [[[outputs]]]
#            out1 = "the cheese is ready"