tree: 2793dd066088cfdf4d70a55a18e0bc074045d3d1 [path history] [tgz]
  1. datasync-workflow-manager/
  2. logs/
  3. mft-callback-listener/
  4. workflow-engine-client/
  5. workflow-engine-controller/
  6. workflow-engine-core/
  7. workflow-engine-stubs/
  8. workflow-engine-worker/
  9. pom.xml
  10. README.md
data-orchestrator/workflow-engine/README.md

Service Execution Order

  • org.apache.airavata.datalake.workflow.engine.controller.Controller
  • org.apache.airavata.datalake.workflow.engine.worker.Participant
  • org.apache.airavata.datalake.workflow.engine.wm.datasync.DataSyncWorkflowManager

Configure the participant with new tasks

  • Extend the task class by BlockingTask or NonBlockingTask class
  • Implement methods
  • Annotate the class with @BlockingTaskDef or @NonBlockingTaskDef annotations. See ExampleBlockingTask and ExampleNonBlockingTask
  • Register task in src/main/resources/task-list.yaml