Run

id: cloud_run_run_existing_job
namespace: company.team

inputs:
  - id: gcp_region
    type: STRING
    defaults: europe-west1
  - id: job_name
    type: STRING
    defaults: prod-etl-job

tasks:
  - id: run_existing_job
    type: io.kestra.plugin.ee.gcp.cloudrun.Run
    projectId: "{{ secret('GCP_PROJECT_ID') }}"
    region: "{{ inputs.gcp_region }}"
    jobName: "{{ inputs.job_name }}"
    serviceAccount: "{{ secret('GOOGLE_SA') }}"
    wait: true
    completionCheckInterval: PT10S

id: cloud_run_run_with_overrides
namespace: company.team

tasks:
  - id: run_existing_job
    type: io.kestra.plugin.ee.gcp.cloudrun.Run
    projectId: "{{ secret('GCP_PROJECT_ID') }}"
    region: europe-west1
    jobName: prod-etl-job
    serviceAccount: "{{ secret('GOOGLE_SA') }}"
    containerEnvironment:
      RUN_ID: "{{ execution.id }}"
      ENVIRONMENT: prod

  - id: log_result
    type: io.kestra.plugin.core.log.Log
    message: "Execution {{ outputs.run_existing_job.executionName }} finished with state {{ outputs.run_existing_job.state }}"

id: cloud_run_scheduled_fire_and_forget
namespace: company.team

triggers:
  - id: nightly
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "0 2 * * *"

tasks:
  - id: run_existing_job
    type: io.kestra.plugin.ee.gcp.cloudrun.Run
    projectId: "{{ secret('GCP_PROJECT_ID') }}"
    region: europe-west1
    jobName: nightly-batch-job
    serviceAccount: "{{ secret('GOOGLE_SA') }}"
    wait: false