query modified fix

serhiimakogon · Dec 27, 2022 · 38ca191 · 38ca191
1 parent c62b07b
commit 38ca191
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ksql/client/client.go b/ksql/client/client.go
@@ -66,7 +66,7 @@ func (c *Client) ExecuteQuery(ctx context.Context, name, qType, query string) (s
 
 		if res.ErrorCode != 0 {
 			err = fmt.Errorf("invalid ksql response %s", res.Message)
-			if strings.HasPrefix(query, "DROP") && queryModified {
+			if strings.HasPrefix(query, "DROP") && !queryModified {
 				if terminateQuery, shouldModify := c.getPreHookTerminateQuery(res.Message); shouldModify {
 					query = terminateQuery + " " + query
 				}