Skip to content

Commit facc90a

Browse files
committed
1
1 parent 975175e commit facc90a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

cassandra/connection.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -673,7 +673,7 @@ def __init__(self, start_port: int, end_port: int):
673673
self.start_port = start_port
674674
self.end_port = end_port
675675

676-
def generate(self, shard_id, total_shards):
676+
def generate(self, shard_id: int, total_shards: int) -> Generator[int]:
677677
start = random.randrange(self.start_port, self.end_port)
678678
available_ports = itertools.chain(range(start, self.end_port), range(self.start_port, start))
679679
for port in available_ports:

0 commit comments

Comments
 (0)