Hi team, have a question about flytekit python sdk. I am trying to get a list of executions of a particular workflow from flyteadmin but I want to filter them based on values of input parameters to the executions. I'm trying to do this but I can't figure out what to provide for the first parameter to different filter methods like
Equal()
. Is it possible to filter executions by input parameter values?
Copy code
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)
t
tall-lock-23197
11/02/2022, 3:21 PM
I don’t think filtering executions by input params is supported yet. cc: @thankful-minister-83577