Honor the idempotent flag for retries

scylladb · Nov 18, 2024 · b696192 · b696192
1 parent 64cddbe
commit b696192
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/query_executor.go b/query_executor.go
@@ -149,7 +149,8 @@ func (q *queryExecutor) do(ctx context.Context, qry ExecutableQuery, hostIter Ne
 
 		// Exit if the query was successful
 		// or no retry policy defined
-		if iter.err == nil || rt == nil {
+		// or query is not marked as idempotent
+		if iter.err == nil || rt == nil || !qry.IsIdempotent() {
 			return iter
 		}