Hi team, have a question about flytekit python sdk...
# flytekit
s
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
I don’t think filtering executions by input params is supported yet. cc: @Yee
s
Ok, thank you.
155 Views