From e4527f0839a73fecf7e453455fe24fe3c8bec7d5 Mon Sep 17 00:00:00 2001
From: Robin Tang <rtang.cs@gmail.com>
Date: Thu, 26 Sep 2024 11:32:10 -0700
Subject: [PATCH] More.

---
 clients/snowflake/snowflake.go | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

diff --git a/clients/snowflake/snowflake.go b/clients/snowflake/snowflake.go
index fb46100cd..5651b19d4 100644
--- a/clients/snowflake/snowflake.go
+++ b/clients/snowflake/snowflake.go
@@ -14,7 +14,6 @@ import (
 	"github.com/artie-labs/transfer/lib/kafkalib"
 	"github.com/artie-labs/transfer/lib/optimization"
 	"github.com/artie-labs/transfer/lib/sql"
-	"github.com/artie-labs/transfer/lib/typing"
 )
 
 type Store struct {
@@ -47,12 +46,7 @@ func (s *Store) Sweep() error {
 		return err
 	}
 
-	snowflakeDialect, err := typing.AssertType[dialect.SnowflakeDialect](s.Dialect())
-	if err != nil {
-		return err
-	}
-
-	return shared.Sweep(s, tcs, snowflakeDialect.BuildSweepQuery)
+	return shared.Sweep(s, tcs, s.dialect().BuildSweepQuery)
 }
 
 func (s *Store) Dialect() sql.Dialect {