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):
|
pre_partition_state, post_partition_state):
|
||||||
assert pre_partition_state is not None
|
assert pre_partition_state is not None
|
||||||
partition_timestamps = {}
|
partition_timestamps = {}
|
||||||
for part in pre_partition_state:
|
|
||||||
partition_timestamps[part.partition_name] = part.version
|
|
||||||
for part in post_partition_state:
|
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])
|
max(part.version, partition_timestamps[part.partition_name])
|
||||||
return [
|
return [
|
||||||
"--partition_timestamps",
|
"--partition_timestamps",
|
||||||
|
Reference in New Issue
Block a user