1 files changed, 4 insertions, 9 deletions
diff --git a/src/nxt_var.c b/src/nxt_var.c
index 0a722d17..458ba678 100644
--- a/src/nxt_var.c
+++ b/src/nxt_var.c
@@ -494,17 +494,12 @@ nxt_var_query(nxt_task_t *task, nxt_var_query_t *query, nxt_var_t *var,
             continue;  /* NXT_DECLINED */
         }
 
-        ret = nxt_var_index[index](task, query, value, query->ctx);
+        ret = nxt_var_index[index](task, value, query->ctx);
+        if (nxt_slow_path(ret != NXT_OK)) {
+            goto fail;
+        }
 
         value = NULL;
-
-        if (ret != NXT_OK) {
-            if (nxt_slow_path(ret != NXT_AGAIN)) {
-                goto fail;
-            }
-
-            query->waiting++;
-        }
     }
 
     query->spare = value;