Samuel Tober
08/17/2021, 8:46 AMKevin Kho
def get_flow_run(flow_run_id: str) -> PrefectFlowRun:
client = Client()
response = client.graphql(
f"""
query {{
flow_run_by_pk ( id: "{flow_run_id}" ),
{{
id,
flow {{
id,
name,
version
}}
state,
start_time,
end_time,
state_message
task_runs {{
id,
state,
state_message,
start_time,
end_time,
task {{
id,
name,
slug,
type
}}
}}
}}
}}"""
)
return