Skip to content

Commit 1ed5042

Browse files
committed
Handle asyncio.TimeoutError
1 parent c0c011c commit 1ed5042

File tree

1 file changed

+4
-1
lines changed
  • src/dstack/_internal/server/background/pipeline_tasks

1 file changed

+4
-1
lines changed

src/dstack/_internal/server/background/pipeline_tasks/base.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -299,7 +299,10 @@ async def start(self):
299299
self._fetch_event.wait(),
300300
timeout=self._next_fetch_delay(empty_fetch_count),
301301
)
302-
except TimeoutError:
302+
except (
303+
asyncio.TimeoutError, # < Python 3.11
304+
TimeoutError, # >= Python 3.11
305+
):
303306
pass
304307
empty_fetch_count += 1
305308
self._fetch_event.clear()

0 commit comments

Comments
 (0)