Italo Barros
requests.exceptions.SSLError: HTTPSConnectionPool(host='<http://api.prefect.io|api.prefect.io>', port=443): Max retries exceeded with url: / (Caused by SSLError(SSLEOFError(8, 'EOF occurred in violation of protocol (_ssl.c:852)'),))
Numline1
Ofir
POST /model
Eren Bilaloglu
Charles Leung
Robert Banick
import asyncio from prefect.states import State from prefect.client import get_client MAX_RUNS_TO_DELETE = 5000 PREFECT_OFFSET_MAX = 200 async def remove_all_flows(): client = get_client() for i in range(0, MAX_RUNS_TO_DELETE, PREFECT_OFFSET_MAX): flow_runs = await client.read_flow_runs(offset=i) for flow_run in flow_runs: if flow_run.state_name == "Late": flow_id = flow_run.id print("deleting", flow_id) await client.set_flow_run_state(flow_run_id=flow_id, state=State(type="CANCELLED")) asyncio.run(remove_all_flows())
pydantic.errors.PydanticUserError: `StateCreate` is not fully defined; you should define all referenced types, then call `StateCreate.model_rebuild()`.
Valentin Baert
Chris Leber
file_list = ['./file_1.txt', './file_2.txt', './file_3.txt', './file_4.txt', './file_5.txt', './file_6.txt', './file_7.txt', ..., './file_100.txt'] @task def test_task(input_file): result = some_function(input_file) return result def ecs_cluster(n_workers=4): """Start a ecs cluster using the same image as the flow run""" return ECSCluster( n_workers=n_workers, image=prefect.context.image, region_name="us-east-1" ) with Flow( "test flow", storage=S3(bucket="storage"), run_config=ECSRun(task_definition=task_definition), ) as flow: test_task.map(input_file=file_list) flow.executor = DaskExecutor( cluster_class=ecs_cluster, cluster_kwargs={"n_workers": 10} )
Jason
RuntimeError: Timed out while attempting to connect to ephemeral Prefect API server.
hagai
Unknown setting 'PREFECT_SERVER_ALLOW_EPHEMERAL_MODE'. (type=value_error)
prefect config unset PREFECT_SERVER_ALLOW_EPHEMERAL_MODE
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.