We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e45068a commit afacf70Copy full SHA for afacf70
paimon-python/pypaimon/write/file_store_write.py
@@ -84,7 +84,7 @@ def close(self):
84
writer.close()
85
self.data_writers.clear()
86
87
- def _seq_number_stats(self, partition: Tuple) -> dict[int, int]:
+ def _seq_number_stats(self, partition: Tuple) -> Dict[int, int]:
88
buckets = self.max_seq_numbers.get(partition)
89
if buckets is None:
90
buckets = self._load_seq_number_stats(partition)
0 commit comments