Abort Detached Queries.

artie-labs · Apr 25, 2024 · a58a846 · a58a846
1 parent f16981d
commit a58a846
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/clients/snowflake/snowflake.go b/clients/snowflake/snowflake.go
@@ -97,13 +97,21 @@ func (s *Store) reestablishConnection() error {
 		return nil
 	}
 
+	params := make(map[string]*string)
+
+	// https://docs.snowflake.com/en/sql-reference/parameters#abort-detached-query
+	params["ABORT_DETACHED_QUERY"] = ptr.ToString(fmt.Sprint(true))
+
 	cfg := &gosnowflake.Config{
 		Account:     s.config.Snowflake.AccountID,
 		User:        s.config.Snowflake.Username,
 		Password:    s.config.Snowflake.Password,
 		Warehouse:   s.config.Snowflake.Warehouse,
 		Region:      s.config.Snowflake.Region,
 		Application: s.config.Snowflake.Application,
+
+		// Try this as our params.
+		Params: params,
 	}
 
 	if s.config.Snowflake.Host != "" {