缩进

文本方式支持首行缩进。但 Python 中缩进也是语法结构，会影响程序的含义。

然而，从之前的例子中我们已经看到，可以使用节点构造函数来提供缩进，用以显示定义结构。

  1. import os
  2. from ecflow import Defs,Suite,Family,Task,Edit,Trigger,Complete,Event,Meter,Time,Day,Date
  4. print("Creating suite definition")
  5. home = os.path.join(os.getenv("HOME"), "course")
  6. defs = Defs(
  7.         Suite("test",
  8.             Edit(ECF_INCLUDE=home,ECF_HOME=home),
  9.             Family("f1",
  10.                 Edit(SLEEP=20),
  11.                 Task("t1", Meter("progress", 1, 100, 90)),
  12.                 Task("t2", Trigger("t1 == complete"),Event("a"),Event("b")),
  13.                 Task("t3", Trigger("t2:a")),
  14.                 Task("t4", Trigger("t2 == complete"), Complete("t2:b")),
  15.                 Task("t5", Trigger("t1:progress ge 30")),
  16.                 Task("t6", Trigger("t1:progress ge 60")),
  17.                 Task("t7", Trigger("t1:progress ge 90"))),
  18.             Family("f2",
  19.                 Edit(SLEEP=20),
  20.                 Task("t1", Time( "00:30 23:30 00:30" )),
  21.                 Task("t2", Day( "sunday" )),
  22.                 Task("t3", Date("1.*.*"), Time("12:00")),
  23.                 Task("t4", Time("+00:02")),
  24.                 Task("t5", Time("00:02")))))
  25. print(defs)
  27. print("Checking job creation: .ecf -> .job0") 
  28. print(defs.check_job_creation())
  30. print("Checking trigger expressions")
  31. assert len(defs.check()) == 0, defs.check()
  33. print("Saving definition to file 'test.def'")
  34. defs.save_as_defs("test.def")

我们还可以利用 Python 的 with 语句实现缩进。

下面将前一个例子用 with 语句改写。

  1. #!/usr/bin/env python2.7
  2. import os
  3. import ecflow
  4. import sys
  6. version = sys.version_info 
  7. if version[1] < 7: 
  8.     print "This example requires python version 2.7, but found : " + str(version)
  9.     exit(0)
  11. print "Creating suite definition"  
  12. with ecflow.Defs() as defs: 
  14.     with defs.add_suite("test") as suite:
  16.         suite.add_variable("ECF_INCLUDE", os.path.join(os.getenv("HOME"),  "course"))
  17.         suite.add_variable("ECF_HOME",    os.path.join(os.getenv("HOME"),  "course"))
  19.         with suite.add_family("f1") as f1:
  20.             f1.add_variable("SLEEP", 20)
  21.             f1.add_task("t1").add_meter("progress", 1, 100, 90)
  22.             f1.add_task("t2").add_trigger("t1 eq complete").add_event("a").add_event("b")
  23.             f1.add_task("t3").add_trigger("t2:a")  
  24.             f1.add_task("t4").add_trigger("t2 eq complete").add_complete("t2:b")  
  25.             f1.add_task("t5").add_trigger("t1:progress ge 30")  
  26.             f1.add_task("t6").add_trigger("t1:progress ge 60")  
  27.             f1.add_task("t7").add_trigger("t1:progress ge 90") 
  29.         with suite.add_family("f2") as f2:        
  30.             f2.add_variable("SLEEP", 20)
  31.             f2.add_task("t1").add_time("00:30 23:30 00:30")
  32.             f2.add_task("t2").add_day("sunday")
  33.             f2.add_task("t3").add_date(1, 0, 0).add_time(12, 0)
  34.             f2.add_task("t4").add_time(0, 2, True)
  35.             f2.add_task("t5").add_time(0, 2)
  37.     print defs
  39.     print "Checking job creation: .ecf -> .job0"   
  40.     print defs.check_job_creation()
  42.     print "Checking trigger expressions"
  43.     print defs.check()
  45.     print "Saving definition to file 'test.def'"
  46.     defs.save_as_defs("test.def")

另一种实现方式：

  1. from ecflow import Defs,Suite,Family,Task,Edit,Trigger,Complete,Event,Meter,Time,Day,Date
  2. import os
  3. import sys
  5. version = sys.version_info
  6. if version[1] < 7:
  7.     print "This example requires python version 2.7, but found : " + str(version)
  8.     exit(0)
  10. print "Creating suite definition" 
  11. with Defs() as defs:
  13.     with defs.add_suite("test") as suite:
  15.         suite += Edit(ECF_HOME=os.path.join(os.getenv("HOME"),  "course"))
  16.         suite += Edit(ECF_INCLUDE =os.path.join(os.getenv("HOME"),  "course"))
  18.     with suite.add_family("f1") as f1:
  19.         f1 += Edit(SLEEP=20)
  20.         f1 += Task("t1", Meter("progress", 1, 100, 90))
  21.         f1 += Task("t2", Trigger("t1 == complete"), Event("a"), Event("b"))
  22.         f1 += Task("t3", Trigger("t2:a"))
  23.         f1 += Task("t4", Trigger("t2 == complete"), Complete("t2:b"))
  24.         f1 += Task("t5", Trigger("t1:progress ge 30"))
  25.         f1 += Task("t6", Trigger("t1:progress ge 60"))
  26.         f1 += Task("t7", Trigger("t1:progress ge 90"))
  28.     with suite.add_family("f2") as f2:       
  29.         f2 += Edit(SLEEP=20)
  30.         f2 += Task("t1", Time("00:30 23:30 00:30"))
  31.         f2 += Task("t2", Day("sunday"))
  32.         f2 += Task("t3", Date(1, 0, 0), Time(12, 0))
  33.         f2 += Task("t4", Time(0, 2, True))
  34.         f2 += Task("t5", Time(0, 2))
  36. print(defs)
  38. print("Checking job creation: .ecf -> .job0")
  39. print(defs.check_job_creation())
  41. print("Checking trigger expressions")
  42. print(defs.check())
  44. print("Saving definition to file 'test.def'")
  45. defs.save_as_defs("test.def")

译者注：因为业务尚未大规模使用 ecFlow，所以还没有标准化的编写方法。个人感觉使用 with 语句更具有扩展性。