vertexai_workflow_launch_steps_table.yaml

main:
  params: [event]
  steps:
    - trainingPipelineCheck:
        switch:
          - condition: ${not("google.cloud.aiplatform.ui.PipelineService.CreateTrainingPipeline" == event.data.protoPayload.methodName)}
            next: end
    # proceed further only when we have the CreateTrainingPipeline event
    - run:
        call: googleapis.workflowexecutions.v1.projects.locations.workflows.executions.run
        args:
            workflow_id: "vertexai_pipeline_launched_clone_bigquery_table"
            argument: 
              trainingPipelineId: ${text.split(event.data.protoPayload.response.name,"/")[5]}
        result: runResult
    - final:
        return: ${runResult}