From 4323642f0e99865a8f0f336884c910e3716fe3b6 Mon Sep 17 00:00:00 2001
From: Yevgeny Pats <16490766+yevgenypats@users.noreply.github.com>
Date: Tue, 14 Feb 2023 12:01:35 +0200
Subject: [PATCH] fix: Set _cq_id not null for all tables

---
 plugins/destination/plugin.go | 1 -
 1 file changed, 1 deletion(-)

diff --git a/plugins/destination/plugin.go b/plugins/destination/plugin.go
index 5c3c0995d4..edab723035 100644
--- a/plugins/destination/plugin.go
+++ b/plugins/destination/plugin.go
@@ -297,7 +297,6 @@ func setCqIDNotNullColumnForTables(tables []*schema.Table) {
 		for i, c := range table.Columns {
 			if c.Name == schema.CqIDColumn.Name {
 				table.Columns[i].CreationOptions.NotNull = true
-				return
 			}
 		}
 		setCqIDNotNullColumnForTables(table.Relations)