we shouldn't be escaping the sql statement (#206)

Snowflake-Labs · Jun 3, 2020 · a4c5c84 · a4c5c84
1 parent bcb850c
commit a4c5c84
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/snowflake/task.go b/pkg/snowflake/task.go
@@ -153,7 +153,7 @@ func (tb *TaskBuilder) Create() string {
 	}
 
 	if tb.sql_statement != "" {
-		q.WriteString(fmt.Sprintf(` AS %v`, EscapeString(tb.sql_statement)))
+		q.WriteString(fmt.Sprintf(` AS %v`, tb.sql_statement))
 	}
 
 	return q.String()
@@ -238,7 +238,7 @@ func (tb *TaskBuilder) ChangeCondition(newCondition string) string {
 
 // ChangeSqlStatement returns the sql that will update the sql the task executes.
 func (tb *TaskBuilder) ChangeSqlStatement(newStatement string) string {
-	return fmt.Sprintf(`ALTER TASK %v MODIFY AS %v`, tb.QualifiedName(), EscapeString(newStatement))
+	return fmt.Sprintf(`ALTER TASK %v MODIFY AS %v`, tb.QualifiedName(), newStatement)
 }
 
 // Suspend returns the sql that will suspend the task.