Hi everyone, While running my flow I got some of these msg in the agent logs

orion_agent-orion_server-1  | 2022-09-06 00:21:29,528 - distributed.worker - WARNING - Compute Failed
orion_agent-orion_server-1  | Key:       1843a132-66f7-45c1-9c76-9736ca31cd4a
orion_agent-orion_server-1  | Function:  begin_task_run
orion_agent-orion_server-1  | args:      ()
orion_agent-orion_server-1  | kwargs:    {'task': <prefect.tasks.Task object at 0x7f28a2f18a60>, 'task_run': TaskRun(id=UUID('9ac621e9-cac9-4ff7-813e-da0ce5d2bda3'), created=DateTime(2022, 9, 6, 0, 15, 11, 280979, tzinfo=Timezone('+00:00')), updated=DateTime(2022, 9, 6, 0, 15, 12, 995201, tzinfo=Timezone('+00:00')), name='download_xml-39058d84-636', flow_run_id=UUID('258498db-6397-412e-a79a-39f252b8316a'), task_key='lib.dask_context.dask_context.<locals>._dask_task', dynamic_key='636', cache_key=None, cache_expiration=None, task_version=None, empirical_policy=TaskRunPolicy(max_retries=0, retry_delay_seconds=0.0, retries=15, retry_delay=2), tags=['map_process'], state_id=UUID('79733d18-24d6-43b5-9f5f-1b04f3022edd'), task_inputs={'args': [TaskRunResult(input_type='task_run', id=UUID('fb87e646-0e3b-4647-abe5-8dea70156bbd'))], 'kwargs': []}, state_type=StateType.PENDING, state_name='Pending', run_count=0, expected_start_time=DateTime(2022, 9, 6, 0, 15, 11, 280780, tzinfo=Timezone('+00:00')), next_scheduled_start_time=None, start_
orion_agent-orion_server-1  | Exception: "RuntimeError('The connection pool was closed while 1 HTTP requests/responses were still in-flight.')"

are they the attempts of the task that failed and are going to retry? or are they something else?

Hi Ian, can you give an example code that causes this error?