diff --git a/src/AsyncQueue.php b/src/AsyncQueue.php
index cffc5bd..f9ed5d1 100644
--- a/src/AsyncQueue.php
+++ b/src/AsyncQueue.php
@@ -118,11 +118,15 @@ public function getJobFromId($queue, $id)
                     
         if($job) {
             $this->markJobAsReserved($job->id);
+
+            $this->database->commit();
             
 			return new DatabaseJob(
 				$this->container, $this, $job, $queue
 			);
         }
+
+        $this->database->commit();
 	}
 
     /**