Skip to content

Commit 9df0a7b

Browse files
committed
Fix CI
1 parent 257f7ee commit 9df0a7b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

coherence/client.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929
import grpc
3030
from pymitter import EventEmitter
3131

32-
from coherence.aggregator import EntryAggregator, SumAggregator, AverageAggregator, PriorityAggregator
32+
from coherence.aggregator import AverageAggregator, EntryAggregator, PriorityAggregator, SumAggregator
3333

3434
from .comparator import Comparator
3535
from .event import MapLifecycleEvent, MapListener, SessionLifecycleEvent
@@ -654,7 +654,7 @@ async def aggregate(
654654
elif isinstance(aggregator, AverageAggregator) and isinstance(value, str):
655655
return cast(R, float(value))
656656
elif isinstance(aggregator, PriorityAggregator):
657-
pri_agg: PriorityAggregator = cast(PriorityAggregator, aggregator)
657+
pri_agg: PriorityAggregator[R] = aggregator
658658
if isinstance(pri_agg.aggregator, SumAggregator) and isinstance(value, str):
659659
return cast(R, float(value))
660660
elif isinstance(pri_agg.aggregator, AverageAggregator) and isinstance(value, str):

0 commit comments

Comments
 (0)