添加meter

meter 类似 event， 但不同于值为 bool 类型（on/off）的 event，meter 的值可以取一个范围内的整数。 其他任务会在 meter 达到某个特定值时被触发。类似 event，meter 有名字，一个 task 可以包含多个 meter。

Ecf脚本

创建新的 task（t5，t6,和t7），当 task t1 的 meter 达到特定值时被触发。 为了通知 ecflow_server， task 必须调用 ecflow_client --meter 命令。

t1.ecf

  1. %include <head.h>
  2. echo "I will now sleep for %SLEEP% seconds"
  3. sleep %SLEEP%
  4. n=1
  5. while [[ $n -le 100 ]]               # Loop 100 times
  6. do
  7.    sleep 1                           # Wait a short time
  8.    ecflow_client --meter=progress $n # Notify ecFlow
  9.    (( n = $n + 1 ))
  10. done
  11. %include <tail.h>

Suite definition

在 suite definition 中添加 meter。

Text

  1. # Definition of the suite test.
  2. suite test
  3.  edit ECF_INCLUDE "$ECF_HOME"    # replace '$ECF_HOME' with the path to your ECF_HOME directory
  4.  edit ECF_HOME    "$ECF_HOME"
  5.  family f1
  6.      edit SLEEP 20
  7.      task t1
  8.          meter progress 1 100 90
  9.      task t2
  10.          trigger t1 eq complete
  11.          event a
  12.          event b
  13.      task t3
  14.          trigger t2:a
  15.      task t4
  16.          trigger t2 eq complete
  17.          complete t2:b
  18.      task t5
  19.          trigger t1:progress ge 30
  20.      task t6
  21.          trigger t1:progress ge 60
  22.      task t7
  23.          trigger t1:progress ge 90
  24.  endfamily
  25. endsuite

Python

  1. import os
  2. from pathlib import Path
  3. from ecflow import Defs, Suite, Task, Family, Edit, Trigger, Event, Complete, Meter
  6. def create_family_f1():
  7.     return Family(
  8.         "f1",
  9.         Edit(SLEEP=20),
  10.         Task("t1",
  11.              Meter("progress", 1, 100, 90)),
  12.         Task("t2",
  13.              Trigger("t1 == complete"),
  14.              Event('a'),
  15.              Event('b')),
  16.         Task("t3",
  17.              Trigger("t2:a")),
  18.         Task("t4",
  19.              Trigger("t2 == complete"),
  20.              Complete("t2:b")),
  21.         Task("t5",
  22.              Trigger("t1:progress ge 30")),
  23.         Task("t6",
  24.              Trigger("t1:progress ge 30")),
  25.         Task("t7",
  26.              Trigger("t1:progress ge 30"))
  27.     )
  30. print("Creating suite definition")
  31. home = os.path.abspath(Path(Path(__file__).parent, "../../../build/course"))
  32. defs = Defs(
  33.     Suite('test',
  34.           Edit(ECF_INCLUDE=home, ECF_HOME=home),
  35.           create_family_f1()))
  36. print(defs)
  38. print("Checking job creation: .ecf -> .job0")
  39. print(defs.check_job_creation())
  41. print("Saving definition to file 'test.def'")
  42. defs.save_as_defs(str(Path(home, "test.def")))
  44. # To restore the definition from file 'test.def' we can use:
  45. # restored_defs = ecflow.Defs("test.def")

运行结果：

  1. $python test.py
  2. Creating suite definition
  3. # 4.8.0
  4. suite test
  5.   edit ECF_INCLUDE '/g3/wangdp/project/study/ecflow/ecflow-tutorial-code/build/course'
  6.   edit ECF_HOME '/g3/wangdp/project/study/ecflow/ecflow-tutorial-code/build/course'
  7.   family f1
  8.     edit SLEEP '20'
  9.     task t1
  10.       meter progress 1 100 90
  11.     task t2
  12.       trigger t1 == complete
  13.       event a
  14.       event b
  15.     task t3
  16.       trigger t2:a
  17.     task t4
  18.       complete t2:b
  19.       trigger t2 == complete
  20.     task t5
  21.       trigger t1:progress ge 30
  22.     task t6
  23.       trigger t1:progress ge 30
  24.     task t7
  25.       trigger t1:progress ge 30
  26.   endfamily
  27. endsuite
  29. Checking job creation: .ecf -> .job0
  31. Saving definition to file 'test.def'

任务

  1. 编辑 definition 文件或 python 脚本，添加上面的修改。
  2. 编辑 t1.ecf，调用 ecflow_client --meter。
  3. 拷贝 t4.ecf 为 t5.ecf，t6.ecf 和 t7.ecf。
  4. 替换 suite

  5. 查看 ecflow_ui

    添加 meter - 图1

  6. 在 meter progress 上右键点击，选择 Edit…

    添加 meter - 图2

  7. 修改 meter 的值，点击 Apply 图标。

添加 meter - 图3