Skip to content

Commit 3365743

Browse files
authored
Update batch-processor.lua
1 parent 94189a0 commit 3365743

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

apisix/utils/batch-processor.lua

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,10 @@ end
7878

7979

8080
function execute_func(premature, self, batch)
81+
if premature then
82+
return
83+
end
84+
8185
-- In case of "err" and a valid "first_fail" batch processor considers, all first_fail-1
8286
-- entries have been successfully consumed and hence reschedule the job for entries with
8387
-- index first_fail to #entries based on the current retry policy.

0 commit comments

Comments
 (0)