Merge branch '4.1' into 4.2

symbiote · May 27, 2019 · 317dba3 · 317dba3
2 parents a0fe9d0 + d0fb2e2
commit 317dba3
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/Services/QueuedJobService.php b/src/Services/QueuedJobService.php
@@ -9,7 +9,6 @@
 use SilverStripe\Control\Email\Email;
 use SilverStripe\Core\Config\Config;
 use SilverStripe\Core\Config\Configurable;
-use SilverStripe\Core\Convert;
 use SilverStripe\Core\Extensible;
 use SilverStripe\Core\Injector\Injectable;
 use SilverStripe\Core\Injector\Injector;
@@ -551,9 +550,12 @@ protected function grabMutex(QueuedJobDescriptor $jobDescriptor)
         // and thus the row would always be affected.
         try {
             DB::query(sprintf(
-                'UPDATE "QueuedJobDescriptor" SET "JobStatus" = \'%s\' WHERE "ID" = %s',
+                'UPDATE "QueuedJobDescriptor" SET "JobStatus" = \'%s\' WHERE "ID" = %s'
+                . ' AND "JobFinished" IS NULL AND "JobStatus" NOT IN (%s)',
                 QueuedJob::STATUS_INIT,
-                $jobDescriptor->ID
+                $jobDescriptor->ID,
+                "'" . QueuedJob::STATUS_RUN . "', '" . QueuedJob::STATUS_COMPLETE . "', '"
+                . QueuedJob::STATUS_PAUSED . "', '" . QueuedJob::STATUS_CANCELLED . "'"
             ));
         } catch (Exception $e) {
             return false;