lemon-horse-4228
11/02/2022, 1:06 AMEqual()
. Is it possible to filter executions by input parameter values?
filters.append(flyte_filters.Equal('launch_plan.name', "my_workflow"))
filters.append(flyte_filters.Equal('inputs.my_wf_input_name', 'demo_1002')) # this doesn't work, gRPC error for 'inputs.my_wf_input_name'
client = SynchronousFlyteClient(cfg=PlatformConfig(endpoint=FLYTE_HOST))
executions, _ = client.list_executions_paginated(
project='avflytesim',
domain='prod',
limit=5
sort_by=Sort('started_at', Sort.Direction.DESCENDING),
filters=filters
)
for ex in executions:
print(ex)
tall-lock-23197
lemon-horse-4228
11/03/2022, 2:47 AM