id: aws_batch_run_existing_job
namespace: company.team

description: >
  Orchestrate an existing AWS Batch job definition on an existing job queue (pure orchestration).
  No resource creation / modification / deletion.

inputs:
  - id: aws_region
    type: STRING
    defaults: eu-central-1
  - id: job_queue_arn
    type: STRING
    defaults: arn:aws:batch:eu-central-1:123456789012:job-queue/prod-etl-queue
  - id: job_definition_arn
    type: STRING
    defaults: arn:aws:batch:eu-central-1:123456789012:job-definition/prod-etl:42

tasks:
  - id: run_batch_job
    type: io.kestra.plugin.ee.aws.batch.Run
    region: "{{ inputs.aws_region }}"
    jobQueue: "{{ inputs.job_queue_arn }}"
    jobDefinition: "{{ inputs.job_definition_arn }}"
    jobName: "prod-etl-{{ execution.id }}"
    parameters:
      run_id: "{{ execution.id }}"
      environment: "prod"
    containerEnvironment:
      KESTRA_EXECUTION_ID: "{{ execution.id }}"
    wait: true
    completionCheckInterval: PT10S
    completionCheckMaxInterval: PT1M
    completionCheckBackoffMultiplier: 1.5
    maxWait: PT2H
    failOnFailedStatus: true
    streamLogs: true
    logGroupName: /aws/batch/job
    logStreamPrefix: "prod-etl-"