diff --git a/flow/workflows/normalize_flow.go b/flow/workflows/normalize_flow.go
index b3fe40a25e..995db58802 100644
--- a/flow/workflows/normalize_flow.go
+++ b/flow/workflows/normalize_flow.go
@@ -70,6 +70,7 @@ func NormalizeFlowWorkflow(
 			received, _ = schemaDeltas.ReceiveWithTimeout(ctx, 5*time.Second, &syncSignal)
 		}
 
+		w.logger.Info("NormalizeTest %v %v", received, stopLoop)
 		if received {
 			tableSchemaDeltas := syncSignal.TableSchemaDeltas
 			if len(tableSchemaDeltas) != 0 {