https://flyte.org logo
#flytekit
Title
# flytekit
s

Sam Blinstein

11/02/2022, 1:06 AM
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)
s

Samhita Alla

11/02/2022, 3:21 PM
I don’t think filtering executions by input params is supported yet. cc: @Yee
s

Sam Blinstein

11/03/2022, 2:47 AM
Ok, thank you.
2 Views