Merge "Temporary hack for making T->S downgrade work"
This commit is contained in:
@@ -1068,10 +1068,11 @@ def GeneratePartitionTimestampFlagsDowngrade(
|
||||
pre_partition_state, post_partition_state):
|
||||
assert pre_partition_state is not None
|
||||
partition_timestamps = {}
|
||||
for part in pre_partition_state:
|
||||
partition_timestamps[part.partition_name] = part.version
|
||||
for part in post_partition_state:
|
||||
partition_timestamps[part.partition_name] = \
|
||||
partition_timestamps[part.partition_name] = part.version
|
||||
for part in pre_partition_state:
|
||||
if part.partition_name in partition_timestamps:
|
||||
partition_timestamps[part.partition_name] = \
|
||||
max(part.version, partition_timestamps[part.partition_name])
|
||||
return [
|
||||
"--partition_timestamps",
|
||||
|
Reference in New Issue
Block a user