LaunchFlexTemplate

LaunchFlexTemplate
Certified
Launch a Flex Template Dataflow job

yaml
type: io.kestra.plugin.gcp.dataflow.LaunchFlexTemplate

Examples

yaml
id: dataflow_flex_template
namespace: company.team

tasks:
  - id: launch
    type: io.kestra.plugin.gcp.dataflow.LaunchFlexTemplate
    projectId: "{{ secret('GCP_PROJECT_ID') }}"
    location: us-central1
    jobName: my-flex-job
    containerSpecGcsPath: gs://my-bucket/flex-templates/spec.json
    parameters:
      inputSubscription: projects/my-project/subscriptions/my-sub
      outputTable: my-project:my_dataset.my_table
    environment:
      maxWorkers: 10