Raviraja Ganta
05/12/2022, 3:07 PMKevin Kho
Raviraja Ganta
05/12/2022, 3:12 PMRaviraja Ganta
05/12/2022, 3:13 PMERROR:prefect.TaskRunner:Unexpected error: OSError(24, 'Too many open files')
error when using Flask APIKevin Kho
flow.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
Client.create_flow_run
Raviraja Ganta
05/12/2022, 3:42 PMRaviraja Ganta
05/13/2022, 10:42 AMget_agent_config
method to test the client. When I use it for triggering the flow it worked.Anna Geller
from 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"},
)