diff --git a/Netdisco/lib/App/Netdisco/Daemon/LocalQueue.pm b/Netdisco/lib/App/Netdisco/Daemon/LocalQueue.pm
index c3a45df1..f3ef561f 100644
--- a/Netdisco/lib/App/Netdisco/Daemon/LocalQueue.pm
+++ b/Netdisco/lib/App/Netdisco/Daemon/LocalQueue.pm
@@ -43,7 +43,8 @@ sub take_jobs {
   return [] if scalar @rows == 0;
 
   debug sprintf "booking out %s jobs to worker %s", (scalar @rows), $wid;
-  $rs->update({wid => $wid});
+  $queue->search({job => { -in => [map {$_->job} @rows] }})
+        ->update({wid => $wid});
 
   return [ map {{$_->get_columns}} @rows ];
 }