Python Sample for executing Cloud Workflow

execute_workflow.pyt

import json

from google.cloud.workflows_v1 import WorkflowsClient
from google.cloud.workflows.executions_v1 import ExecutionsClient
from google.cloud.workflows.executions_v1.types.executions import Execution

project = 'PROJECT ID'
location = 'REGION'
workflow = 'WORKFLOW NAME'

argument = {
    "key1": "val1",
    "key2": "val2"
}

parent = WorkflowsClient().workflow_path(project, location, workflow)

client = ExecutionsClient()
execution = Execution(argument=json.dumps(argument))
response = client.create_execution(parent=parent, execution=execution)
print(f"Created execution: {response.name}")