@@ -437,7 +437,7 @@ async def _synchronize_and_fetch_fallback(
437437 if self ._latest_fallback_sample is None :
438438 try :
439439 self ._latest_fallback_sample = await fallback_fetcher .receive ()
440- except ReceiverError [ Any ] as err :
440+ except ReceiverError as err :
441441 _logger .error (
442442 "Fallback metric fetcher %s failed to fetch next value: %s."
443443 "Using primary metric fetcher." ,
@@ -453,7 +453,7 @@ async def _synchronize_and_fetch_fallback(
453453 while primary_fetcher_sample .timestamp > self ._latest_fallback_sample .timestamp :
454454 try :
455455 self ._latest_fallback_sample = await fallback_fetcher .receive ()
456- except ReceiverError [ Any ] as err :
456+ except ReceiverError as err :
457457 _logger .error (
458458 "Fallback metric fetcher %s failed to fetch next value: %s."
459459 "Using primary metric fetcher." ,
@@ -481,7 +481,7 @@ async def fetch_next_with_fallback(
481481 """
482482 try :
483483 primary = await self ._stream .receive ()
484- except ReceiverError [ Any ] as err :
484+ except ReceiverError as err :
485485 _logger .error (
486486 "Primary metric fetcher %s failed to fetch next value: %s."
487487 "Using fallback metric fetcher." ,
@@ -519,7 +519,7 @@ async def _fetch_next(self) -> Sample[QuantityT] | None:
519519 next_value = None
520520 try :
521521 next_value = await self ._stream .receive ()
522- except ReceiverError [ Any ] as err :
522+ except ReceiverError as err :
523523 _logger .error ("Failed to fetch next value from %s: %s" , self ._name , err )
524524 else :
525525 if self ._is_value_valid (next_value .value ):
0 commit comments