changes

Shopify · Jul 8, 2021 · 723770e · 723770e
1 parent 13b3027
commit 723770e
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/ferry.go b/ferry.go
@@ -712,11 +712,10 @@ func (f *Ferry) Run() {
 	}
 
 	schemaFingerVerifierPrintWg := &sync.WaitGroup{}
-	schemaFingerPrintVerifierContext, stopSchemaFingerprintVerifier := context.WithCancel(ctx)
 	schemaFingerVerifierPrintWg.Add(1)
 	go func() {
 		defer schemaFingerVerifierPrintWg.Done()
-		f.SchemaFingerPrintVerifier.PeriodicallyVerifySchemaFingerprints(schemaFingerPrintVerifierContext)
+		f.SchemaFingerPrintVerifier.PeriodicallyVerifySchemaFingerprints(ctx)
 	}()
 
 	inlineVerifierWg := &sync.WaitGroup{}
@@ -815,14 +814,13 @@ func (f *Ferry) Run() {
 
 	binlogWg.Wait()
 
-	stopSchemaFingerprintVerifier()
-	schemaFingerVerifierPrintWg.Wait()
-
 	f.logger.Info("ghostferry run is complete, shutting down auxiliary services")
 	f.OverallState.Store(StateDone)
 	f.DoneTime = time.Now()
 
 	shutdown()
+
+	schemaFingerVerifierPrintWg.Wait()
 	supportingServicesWg.Wait()
 
 	if f.Config.ProgressCallback.URI != "" {