From 78e5544dab5f2ec3b781ddf9ed80334c4ed7673a Mon Sep 17 00:00:00 2001
From: Oliver Gorwits <oliver@cpan.org>
Date: Fri, 23 Feb 2018 23:47:39 +0000
Subject: [PATCH] avoid skips that go twice past max_deferrals not being
 reduced

---
 Changes                                 | 4 ++++
 lib/App/Netdisco/JobQueue/PostgreSQL.pm | 5 +++--
 2 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/Changes b/Changes
index 294519fb..701166fb 100644
--- a/Changes
+++ b/Changes
@@ -5,6 +5,10 @@
   * use PG COPY for bulk insert of jobs with prefix
   * support IP prefix enum expansion in scheduler
 
+  [BUG FIXES]
+
+  * avoid skips that go twice past max_deferrals not being reduced
+
 2.039010 - 2018-02-22
 
   [NEW FEATURES]
diff --git a/lib/App/Netdisco/JobQueue/PostgreSQL.pm b/lib/App/Netdisco/JobQueue/PostgreSQL.pm
index 31e5a75c..f789db83 100644
--- a/lib/App/Netdisco/JobQueue/PostgreSQL.pm
+++ b/lib/App/Netdisco/JobQueue/PostgreSQL.pm
@@ -61,10 +61,11 @@ sub jq_warm_thrusters {
       backend => setting('workers')->{'BACKEND'},
     }, { for => 'update' }, )->update({ actionset => [] });
 
+    my $deferrals = setting('workers')->{'max_deferrals'} - 1;
     $rs->search({
       backend => setting('workers')->{'BACKEND'},
-      deferrals => { '>' => 0 },
-    }, { for => 'update' }, )->update({ deferrals => \'deferrals - 1' });
+      deferrals => { '>' => $deferrals },
+    }, { for => 'update' }, )->update({ deferrals => $deferrals });
 
     $rs->search({
       backend => setting('workers')->{'BACKEND'},