1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
from __future__ import annotations
class P2PIllegalStateError(RuntimeError):
pass
class P2PConsistencyError(RuntimeError):
pass
class ShuffleClosedError(P2PConsistencyError):
pass
class DataUnavailable(Exception):
"""Raised when data is not available in the buffer"""
class P2POutOfDiskError(OSError):
def __str__(self) -> str:
return (
"P2P ran out of available disk space while temporarily storing transferred data. "
"Please make sure that P2P has enough disk space available by increasing the number of "
"workers or the size of the attached disk."
)
|
