diff options
| author |  Mehrdad Afshari <mmx@google.com> | 2018-06-07 22:50:23 -0700 |
|---|---|---|
| committer | Mehrdad Afshari <mmx@google.com> | 2018-06-07 22:50:23 -0700 |
| commit | 0aaeedcbd40e78af06d99a98a591f3cc975303a7 (patch) | |
| tree | 50caacef792825759e8dafbac89a49ea5298365a /src | |
| parent | c48acb86fd957e8d88416ae28e813baeed3790a4 (diff) | |
Fix inconsistent-return-statements pylint warnings
Diffstat (limited to 'src')
| -rw-r--r-- | src/python/grpcio/grpc/_server.py | 1 | ||||
| -rw-r--r-- | src/python/grpcio/grpc/_utilities.py | 2 | ||||
| -rw-r--r-- | src/python/grpcio/grpc/beta/_server_adaptations.py | 1 | ||||
| -rw-r--r-- | src/python/grpcio/grpc/beta/utilities.py | 2 |
4 files changed, 6 insertions, 0 deletions
diff --git a/src/python/grpcio/grpc/_server.py b/src/python/grpcio/grpc/_server.py index d12a2421cd..042145711b 100644 --- a/src/python/grpcio/grpc/_server.py +++ b/src/python/grpcio/grpc/_server.py @@ -329,6 +329,7 @@ class _RequestIterator(object): request = self._state.request self._state.request = None return request + raise Exception('gRPC Error: Invalid _state') def _next(self): with self._state.condition: diff --git a/src/python/grpcio/grpc/_utilities.py b/src/python/grpcio/grpc/_utilities.py index 25bd1ceae2..d90b34bcbd 100644 --- a/src/python/grpcio/grpc/_utilities.py +++ b/src/python/grpcio/grpc/_utilities.py @@ -116,6 +116,8 @@ class _ChannelReadyFuture(grpc.Future): callable_util.call_logging_exceptions( done_callback, _DONE_CALLBACK_EXCEPTION_LOG_MESSAGE, self) + return True + def cancelled(self): with self._condition: return self._cancelled diff --git a/src/python/grpcio/grpc/beta/_server_adaptations.py b/src/python/grpcio/grpc/beta/_server_adaptations.py index ccafec8951..80ac65b649 100644 --- a/src/python/grpcio/grpc/beta/_server_adaptations.py +++ b/src/python/grpcio/grpc/beta/_server_adaptations.py @@ -305,6 +305,7 @@ def _simple_method_handler(implementation, request_deserializer, response_serializer, None, None, None, _adapt_stream_stream_event( implementation.stream_stream_event)) + raise ValueError() def _flatten_method_pair_map(method_pair_map): diff --git a/src/python/grpcio/grpc/beta/utilities.py b/src/python/grpcio/grpc/beta/utilities.py index b5d8aac71a..fe3ce606c9 100644 --- a/src/python/grpcio/grpc/beta/utilities.py +++ b/src/python/grpcio/grpc/beta/utilities.py @@ -85,6 +85,8 @@ class _ChannelReadyFuture(future.Future): callable_util.call_logging_exceptions( done_callback, _DONE_CALLBACK_EXCEPTION_LOG_MESSAGE, self) + return True + def cancelled(self): with self._condition: return self._cancelled |