type annotations, ug, when did python become Java?

Author: carver

p2p/lightchain.py

@@ -149,7 +149,7 @@ async def get_receipts(self, block_hash: Hash32) -> List[Receipt]:
 
     @alru_cache(maxsize=1024, cache_exceptions=False)
     async def get_account(self, block_hash: Hash32, address: Address) -> Account:
-        return await self._reattempt_on_bad_response(
+        return await self._retry_on_bad_response(
             partial(self._get_account_from_peer, block_hash, address)
         )
 
@@ -192,7 +192,7 @@ async def get_contract_code(self, block_hash: Hash32, address: Address) -> bytes
 
         code_hash = account.code_hash
 
-        return await self._reattempt_on_bad_response(
+        return await self._retry_on_bad_response(
             partial(self._get_contract_code_from_peer, block_hash, address, code_hash)
         )
 
@@ -260,7 +260,7 @@ async def _get_proof(self,
         reply = await self._wait_for_reply(request_id)
         return reply['proof']
 
-    async def _reattempt_on_bad_response(self, make_request_to_peer):
+    async def _retry_on_bad_response(self, make_request_to_peer: Callable[[LESPeer], Any]) -> Any:
         for _ in range(MAX_REQUEST_ATTEMPTS):
             peer = cast(LESPeer, self.peer_pool.highest_td_peer)
             try:

p2p/service.py

@@ -6,10 +6,8 @@
     Any,
     Awaitable,
     Callable,
-    Dict,
     List,
     Optional,
-    Tuple,
     TypeVar
     cast,
 )
@@ -132,17 +130,17 @@ async def _cleanup(self) -> None:
         raise NotImplementedError()
 
 
-def service_timeout(timeout):
+def service_timeout(timeout: int) -> Callable[..., Any]:
     """
     Decorator to time out a method call.
 
     :param timeout: seconds to wait before raising a timeout exception
 
     :raise asyncio.futures.TimeoutError: if the call is not complete before timeout seconds
     """
-    def decorator(func):
+    def decorator(func: Callable[..., Any]) -> Callable[..., Any]:
         @functools.wraps(func)
-        async def wrapped(service: BaseService, *args: Tuple, **kwargs: Dict) -> Any:
+        async def wrapped(service: BaseService, *args: Any, **kwargs: Any) -> Any:
             return await service.wait(
                 func(service, *args, **kwargs),
                 timeout=timeout,