Coverage for /pythoncovmergedfiles/medio/medio/usr/local/lib/python3.11/site-packages/google/cloud/pubsub_v1/publisher/exceptions.py: 77%

1# Copyright 2017, Google LLC All rights reserved. 

2# 

3# Licensed under the Apache License, Version 2.0 (the "License"); 

4# you may not use this file except in compliance with the License. 

5# You may obtain a copy of the License at 

6# 

7# http://www.apache.org/licenses/LICENSE-2.0 

8# 

9# Unless required by applicable law or agreed to in writing, software 

10# distributed under the License is distributed on an "AS IS" BASIS, 

11# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 

12# See the License for the specific language governing permissions and 

13# limitations under the License. 

14 

15from __future__ import absolute_import 

16 

17from google.api_core.exceptions import GoogleAPICallError 

18from google.cloud.pubsub_v1.exceptions import TimeoutError 

19 

20 

21class PublishError(GoogleAPICallError): 

22 pass 

23 

24 

25class MessageTooLargeError(ValueError): 

26 """Attempt to publish a message that would exceed the server max size limit.""" 

27 

28 

29class PublishToPausedOrderingKeyException(Exception): 

30 """Publish attempted to paused ordering key. To resume publishing, call 

31 the resumePublish method on the publisher Client object with this 

32 ordering key. Ordering keys are paused if an unrecoverable error 

33 occurred during publish of a batch for that key. 

34 """ 

35 

36 def __init__(self, ordering_key: str): 

37 self.ordering_key = ordering_key 

38 super(PublishToPausedOrderingKeyException, self).__init__() 

39 

40 

41class FlowControlLimitError(Exception): 

42 """An action resulted in exceeding the flow control limits.""" 

43 

44 

45__all__ = ( 

46 "FlowControlLimitError", 

47 "MessageTooLargeError", 

48 "PublishError", 

49 "TimeoutError", 

50 "PublishToPausedOrderingKeyException", 

51)