https://flyte.org logo
#ask-the-community
Title
# ask-the-community
m

mykyta luzan

05/24/2023, 7:57 PM
Hi, guys! I am running my workflows using airflow. And I want to read outputs of the previous execution before running a new one. How to properly do that using flytekit python api? • How to get recent execution for a particular workflow (latest version)? I know that you can fetch_execution but only with known id • How to check the outputs of this executions? I’ve tried the following:
Copy code
hook = FlyteHook(flyte_conn_id=FLYTE_CONN_ID, project=flyte_project, domain=flyte_domain)
remote = hook.create_flyte_remote()

# workflow = remote.fetch_workflow(flyte_project, flyte_domain, flyte_task)
executions = remote.recent_executions(flyte_project, flyte_domain)
executions_filtered = list(
    filter(
        lambda e: e.spec.launch_plan.name == flyte_task and e.is_done,
        executions,
    )
)
if executions_filtered:
    execution = executions_filtered[0]
    <http://logging.info|logging.info>(f"{execution.id}")
    outputs = execution.outputs
    <http://logging.info|logging.info>(f"{outputs}")
But filtering of executions is not really convenient and the outputs are empty (however they shouldn’t be so)
e

Eduardo Apolinario (eapolinario)

05/24/2023, 9:34 PM
@mykyta luzan, two things: 1.
recent_executions
has a
limit
parameter. 2. make sure to call sync on the execution prior to checking its outputs / nodes.
m

mykyta luzan

05/25/2023, 8:05 AM
Sync works! Thanks
limit
- not very useful in my case. It just set the number of recent executions Is there any better way to filter executions that match a certain workflow/task? I’ve tried to run
execution.flyte_workflow.id == workflow.id
, but
flyte_workflow
returns None
74 Views