From 9408dff0930d6ed1a91c02a8819723732ef9708f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Philip=20Dub=C3=A9?= <philip@peerdb.io>
Date: Tue, 12 Dec 2023 17:39:42 +0000
Subject: [PATCH] print debug

---
 flow/workflows/normalize_flow.go | 1 +
 1 file changed, 1 insertion(+)

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 {