Azkaban Custom DSL Syntax

azkaban-embedded.az

javaprocess('innerJobA') {
  job.class = 'azkaban.executor.SleepJavaJob'
  seconds = 1
  fail = false
  property.with.variable = 'Name of class: ${job.class}'
  arithmetic = (1 + 3) - 2
}

javaprocess('innerJobB') {
  deps = ['innerJobA']
  job.class = 'azkaban.executor.SleepJavaJob'
  seconds = 1
  fail = false
}

javaprocess('innerJobC') {
  deps = ['innerJobA']
  job.class = 'azkaban.executor.SleepJavaJob'
  seconds = 1
  fail = false
}

javaprocess('jobA') {
  job.class = 'azkaban.executor.SleepJavaJob'
  seconds = 1
  fail = false
}

workflow('innerFlow') {
  deps = ['jobA']
  runs = ['innerJobB', 'innerJobC']
}

workflow('flowB') {
  embeds = 'innerFlow'
  deps = ['jobA']
}

workflow('flowC') {
  embeds = 'innerFlow'
  deps = ['jobA']
}

workflow('flowD') {
  embeds = 'innerFlow'
  deps = ['jobA']
}

workflow('embedded') {
  runs = ['jobB', 'jobC', 'jobD']
}