Get hands-on experience with 20+ free Google Cloud products and $300 in free credit for new customers.

Filtering workflow executions using python.

Hello, 

I am trying to filter on failed workflow execution by using the ListWorkflowsRequest client library. I have tried to follow the guide in the gcloud filtering documentation but I cant get it to work. I have posted a sample below and line 12 is the problematic line. Thanks

from google.cloud import workflows_v1
from google.cloud.workflows import executions_v1

# Create a client
workflow_client = workflows_v1.WorkflowsClient()
execution_client = executions_v1.ExecutionsClient()
project = "test_project"
location = "europe-west4"
# Initialize request argument(s)
request = workflows_v1.ListWorkflowsRequest(
    parent=f"projects/{project}/locations/{location}",
    filter="STATE:FAILED"
)
# Make the request
workflow_page_result = workflow_client.list_workflows(request=request)
# Handle the response
with open("./workflows.txt", "w") as workflow_file:
    for workflow_response in workflow_page_result:
        name = workflow_response.name
        request = executions_v1.ListExecutionsRequest(
            parent=name,
        )
        execution_page_result = execution_client.list_executions(request=request)
        # Handle the response
        for execution_response in execution_page_result:
            print(execution_response)
        workflow_file.write(name)

 

0 2 2,119
2 REPLIES 2
Top Labels in this Space
Top Solution Authors