tests workaround

jitsucom · Jul 17, 2024 · bccd231 · bccd231
1 parent 30e81f5
commit bccd231
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/bulkerlib/implementations/sql/clickhouse.go b/bulkerlib/implementations/sql/clickhouse.go
@@ -319,6 +319,7 @@ func (ch *ClickHouse) OpenTx(ctx context.Context) (*TxSQLAdapter, error) {
 			return nil, fmt.Errorf("failed to open connection: %v", err)
 		}
 		db = NewConWithDB(sessionDb, c, sessionId)
+		time.Sleep(1 * time.Second)
 	} else {
 		var err error
 		db, err = ch.dataSource.Conn(ctx)

diff --git a/bulkerlib/implementations/sql/tx_wrapper.go b/bulkerlib/implementations/sql/tx_wrapper.go
@@ -185,6 +185,7 @@ type ConWithDB struct {
 }
 
 func NewConWithDB(db *sql.DB, con *sql.Conn, sessionId string) *ConWithDB {
+	fmt.Println("OPEN", sessionId)
 	return &ConWithDB{db: db, con: con, sessionId: sessionId}
 }
-Original file line number
+Diff line change
@@ Expand Up / @@ -185,6 +185,7 @@ type ConWithDB struct { @@
     }
     func NewConWithDB(db *sql.DB, con *sql.Conn, sessionId string) *ConWithDB {
+    	fmt.Println("OPEN", sessionId)
     	return &ConWithDB{db: db, con: con, sessionId: sessionId}
     }
@@ Expand Down @@