Coverage for /pythoncovmergedfiles/medio/medio/usr/local/lib/python3.11/site-packages/anyio/_core/_exceptions.py: 52%

1from __future__ import annotations 

2 

3import sys 

4from collections.abc import Generator 

5from textwrap import dedent 

6from typing import Any 

7 

8if sys.version_info < (3, 11): 

9 from exceptiongroup import BaseExceptionGroup 

10 

11 

12class BrokenResourceError(Exception): 

13 """ 

14 Raised when trying to use a resource that has been rendered unusable due to external 

15 causes (e.g. a send stream whose peer has disconnected). 

16 """ 

17 

18 

19class BrokenWorkerProcess(Exception): 

20 """ 

21 Raised by :meth:`~anyio.to_process.run_sync` if the worker process terminates abruptly or 

22 otherwise misbehaves. 

23 """ 

24 

25 

26class BrokenWorkerIntepreter(Exception): 

27 """ 

28 Raised by :meth:`~anyio.to_interpreter.run_sync` if an unexpected exception is 

29 raised in the subinterpreter. 

30 """ 

31 

32 def __init__(self, excinfo: Any): 

33 # This was adapted from concurrent.futures.interpreter.ExecutionFailed 

34 msg = excinfo.formatted 

35 if not msg: 

36 if excinfo.type and excinfo.msg: 

37 msg = f"{excinfo.type.__name__}: {excinfo.msg}" 

38 else: 

39 msg = excinfo.type.__name__ or excinfo.msg 

40 

41 super().__init__(msg) 

42 self.excinfo = excinfo 

43 

44 def __str__(self) -> str: 

45 try: 

46 formatted = self.excinfo.errdisplay 

47 except Exception: 

48 return super().__str__() 

49 else: 

50 return dedent( 

51 f""" 

52 {super().__str__()} 

53 

54 Uncaught in the interpreter: 

55 

56 {formatted} 

57 """.strip() 

58 ) 

59 

60 

61class BusyResourceError(Exception): 

62 """ 

63 Raised when two tasks are trying to read from or write to the same resource 

64 concurrently. 

65 """ 

66 

67 def __init__(self, action: str): 

68 super().__init__(f"Another task is already {action} this resource") 

69 

70 

71class ClosedResourceError(Exception): 

72 """Raised when trying to use a resource that has been closed.""" 

73 

74 

75class DelimiterNotFound(Exception): 

76 """ 

77 Raised during 

78 :meth:`~anyio.streams.buffered.BufferedByteReceiveStream.receive_until` if the 

79 maximum number of bytes has been read without the delimiter being found. 

80 """ 

81 

82 def __init__(self, max_bytes: int) -> None: 

83 super().__init__( 

84 f"The delimiter was not found among the first {max_bytes} bytes" 

85 ) 

86 

87 

88class EndOfStream(Exception): 

89 """ 

90 Raised when trying to read from a stream that has been closed from the other end. 

91 """ 

92 

93 

94class IncompleteRead(Exception): 

95 """ 

96 Raised during 

97 :meth:`~anyio.streams.buffered.BufferedByteReceiveStream.receive_exactly` or 

98 :meth:`~anyio.streams.buffered.BufferedByteReceiveStream.receive_until` if the 

99 connection is closed before the requested amount of bytes has been read. 

100 """ 

101 

102 def __init__(self) -> None: 

103 super().__init__( 

104 "The stream was closed before the read operation could be completed" 

105 ) 

106 

107 

108class TypedAttributeLookupError(LookupError): 

109 """ 

110 Raised by :meth:`~anyio.TypedAttributeProvider.extra` when the given typed attribute 

111 is not found and no default value has been given. 

112 """ 

113 

114 

115class WouldBlock(Exception): 

116 """Raised by ``X_nowait`` functions if ``X()`` would block.""" 

117 

118 

119def iterate_exceptions( 

120 exception: BaseException, 

121) -> Generator[BaseException, None, None]: 

122 if isinstance(exception, BaseExceptionGroup): 

123 for exc in exception.exceptions: 

124 yield from iterate_exceptions(exc) 

125 else: 

126 yield exception