From 068c67b2e2a4dcca0af067ea697ea6e83362e834 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Philip=20Dub=C3=A9?= <philip@peerdb.io>
Date: Thu, 9 Jan 2025 19:13:15 +0000
Subject: [PATCH] see RunID run

---
 flow/e2e/clickhouse/peer_flow_ch_test.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/flow/e2e/clickhouse/peer_flow_ch_test.go b/flow/e2e/clickhouse/peer_flow_ch_test.go
index 2564deab4..c6381821e 100644
--- a/flow/e2e/clickhouse/peer_flow_ch_test.go
+++ b/flow/e2e/clickhouse/peer_flow_ch_test.go
@@ -110,6 +110,7 @@ func (s ClickHouseSuite) Test_Addition_Removal() {
 		return !rows.Next()
 	})
 
+	runID := env.GetRunID()
 	e2e.SignalWorkflow(env, model.CDCDynamicPropertiesSignal, &protos.CDCFlowConfigUpdate{
 		AdditionalTables: []*protos.TableMapping{
 			{
@@ -123,6 +124,8 @@ func (s ClickHouseSuite) Test_Addition_Removal() {
 		flowStatus := getFlowStatus()
 		return flowStatus == protos.FlowStatus_STATUS_RUNNING
 	})
+	afterAddRunID := env.GetRunID()
+	require.NotEqual(s.t, runID, afterAddRunID)
 
 	_, err = s.Conn().Exec(context.Background(), fmt.Sprintf(`
 		INSERT INTO %s (key) VALUES ('test');
@@ -163,6 +166,8 @@ func (s ClickHouseSuite) Test_Addition_Removal() {
 		flowStatus := getFlowStatus()
 		return flowStatus == protos.FlowStatus_STATUS_RUNNING
 	})
+	afterRemoveRunID := env.GetRunID()
+	require.NotEqual(s.t, runID, afterRemoveRunID)
 
 	_, err = s.Conn().Exec(context.Background(), fmt.Sprintf(`
 	INSERT INTO %s (key) VALUES ('test');