diff --git a/dbt_coves/tasks/blue_green/clone_db.py b/dbt_coves/tasks/blue_green/clone_db.py
index f866cb9..a6a4070 100644
--- a/dbt_coves/tasks/blue_green/clone_db.py
+++ b/dbt_coves/tasks/blue_green/clone_db.py
@@ -3,7 +3,6 @@
 
 from rich.console import Console
 from snowflake.connector import DictCursor
-from snowflake.connector.connection import SnowflakeConnection
 
 console = Console()
 
@@ -141,7 +140,7 @@ def __init__(self, con, threads):
         self.threads = threads
         self.register_command_thread = 0
         self.thread_commands = [[] for _ in range(self.threads)]
-        self.con: SnowflakeConnection = con
+        self.con = con
         self.pending_queries = []
 
     def register_command(self, command: str):