em.md

Trigger Usage

1. pegasus-em create <ensemble name>
2. pegasus-em trigger <ensemble name> <trigger name> <prefix> <pattern> <interval> <workflow script>

• At each interval, file names matching the given pattern(s) and which have a modification date s.t. (time now - interval) <= mod date < time now, will be given as arguments to the workflow script. The workflow will be planned and submitted as <ensemble name>.<prefix>_<time now or runXXX>.

• Example:

  pegasus-em create casa
  pegasus-em trigger casa 10s_csv csv /inputs/*.csv 10m worfklow1.py
  pegasus-em trigger casa 10s_csv jpg /inputs/*.jpg 10m worfklow2.py
  .
  .
  
  #casa.csv_1000000
  #casa.csv_1000001
  #casa.jpg_1000000
  .
  pegasus-em trigger --stop casa csv
  pegasus-em trigger --stop casa jpg
  

3. Stopping condition? Specify date?
4. Ensemble manager supports priorities (10 being the highest). Should this be added in to the trigger command so that all workflows created as a result of that trigger receive the assigned priority?

• pegasus-em trigger -p 10 <ensemble name> <trigger name> <prefix> <pattern> <interval> <workflow script>