From e0b4fd4759a6b2a37c2e10425d43db33620176cc Mon Sep 17 00:00:00 2001 From: Gaurav Ghildiyal Date: Mon, 10 Apr 2023 19:49:30 -0700 Subject: [PATCH] Perform non-rate-limited migration --- pkg/neg/syncers/transaction.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/pkg/neg/syncers/transaction.go b/pkg/neg/syncers/transaction.go index 7922cd9578..ab513b6aed 100644 --- a/pkg/neg/syncers/transaction.go +++ b/pkg/neg/syncers/transaction.go @@ -290,7 +290,12 @@ func (s *transactionSyncer) syncInternalImpl() error { // Identification of migration endpoints should happen before we filter out // the transaction endpoints. Not doing so could result in an attempt to // attach an endpoint which is still undergoing detachment-due-to-migration. - findAndFilterMigrationEndpoints(addEndpoints, removeEndpoints) + _, migratingEndpointsInRemoveSet := findAndFilterMigrationEndpoints(addEndpoints, removeEndpoints) + + // TODO(gauravkghildiyal): Implement rate limited migration-detachment. + for zone, endpointSet := range migratingEndpointsInRemoveSet { + removeEndpoints[zone] = removeEndpoints[zone].Union(endpointSet) + } } // Filter out the endpoints with existing transaction