Raviraja Ganta
05/12/2022, 3:07 PMKevin Kho
05/12/2022, 3:09 PMRaviraja Ganta
05/12/2022, 3:12 PMERROR:prefect.TaskRunner:Unexpected error: OSError(24, 'Too many open files')
error when using Flask APIKevin Kho
05/12/2022, 3:19 PMflow.run()
with an API? I think it will be easier if you trigger a Prefect Cloud Flow RunRaviraja Ganta
05/12/2022, 3:21 PMKevin Kho
05/12/2022, 3:26 PMClient.create_flow_run
Raviraja Ganta
05/12/2022, 3:42 PMget_agent_config
method to test the client. When I use it for triggering the flow it worked.Anna Geller
05/13/2022, 1:07 PMfrom prefect import Flow
from prefect.tasks.prefect import create_flow_run, wait_for_flow_run
PROJECT_NAME = "community"
with Flow("sample_flow") as flow:
child_run_id = create_flow_run(
flow_name="child_flow",
project_name=PROJECT_NAME,
task_args={"name": "Friendly name for a DAG node"},
)
extract_load_wait_task = wait_for_flow_run(
child_run_id,
raise_final_state=True,
stream_logs=True,
task_args={"name": "Friendly wait task name"},
)