@@ -161,7 +161,7 @@ def _parse_partition_map(rows):
161161
162162
163163def get_columns (database , table ):
164- """ Gather the columns list via the database command tool. """
164+ """Gather the columns list via the database command tool."""
165165 if not isinstance (table , partitionmanager .types .Table ) or not isinstance (
166166 table .name , partitionmanager .types .SqlInput
167167 ):
@@ -171,8 +171,8 @@ def get_columns(database, table):
171171
172172
173173def _parse_columns (table , rows ):
174- """ Read the columns description and return a list of the columns, where
175- each entry is a dict containing Field and Type. """
174+ """Read the columns description and return a list of the columns, where
175+ each entry is a dict containing Field and Type."""
176176 log = logging .getLogger ("parse_columns" )
177177 if not rows :
178178 raise partitionmanager .types .TableInformationException ("No column information" )
@@ -363,7 +363,7 @@ def _calculate_start_time(last_changed_time, evaluation_time, allowed_lifespan):
363363def _get_rate_partitions_with_implicit_timestamps (
364364 table , filled_partitions , current_position , evaluation_time , active_partition
365365):
366- """ Return a list of PositionPartitions for use in rate calculations.
366+ """Return a list of PositionPartitions for use in rate calculations.
367367
368368 The partitions are set with implicit timestamps.
369369 """
@@ -413,7 +413,7 @@ def _get_rate_partitions_with_implicit_timestamps(
413413def _get_rate_partitions_with_queried_timestamps (
414414 database , table , partition_list , current_position , evaluation_time , active_partition
415415):
416- """ Return a list of PositionPartitions for use in rate calculations.
416+ """Return a list of PositionPartitions for use in rate calculations.
417417
418418 The partitions' timestamps are explicitly queried.
419419 """
@@ -493,9 +493,11 @@ def _plan_partition_changes(
493493 """
494494 log = logging .getLogger (f"plan_partition_changes:{ table .name } " )
495495
496- filled_partitions , active_partition , empty_partitions = _split_partitions_around_position (
497- partition_list , current_position
498- )
496+ (
497+ filled_partitions ,
498+ active_partition ,
499+ empty_partitions ,
500+ ) = _split_partitions_around_position (partition_list , current_position )
499501 if not empty_partitions :
500502 log .error (
501503 f"Partition { active_partition .name } requires manual ALTER "
0 commit comments