subscription OnAnyJobTask($registration: String) {
  AtmJobTask(owner: $registration, state: created) {
    id
    data
    name
    job {
      id
      data
    }
    state
    message
  }
}