StartServerlessJobRun

id: start_emr_job
namespace: company.team

tasks:
  - id: start_job
    type: io.kestra.plugin.aws.emr.StartServerlessJobRun
    accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
    secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
    region: "eu-central-1"
    applicationId: "00f123abc456xyz"
    executionRoleArn: "arn:aws:iam::123456789012:role/EMRServerlessRole"
    jobName: "sample-spark-job"
    entryPoint: "s3://my-bucket/scripts/spark-app.py"
    jobDriver:
      sparkSubmit:
        entryPointArguments:
          - "--arg1"
          - "value1"