Make jobs as being manually run when manually run

uafrica · Mar 15, 2018 · f5767be · f5767be
1 parent 42aabcb
commit f5767be
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 0 deletions.
diff --git a/src/DelayedJob/Job.php b/src/DelayedJob/Job.php
@@ -114,6 +114,12 @@ class Job
      * @var mixed
      */
     protected $_brokerMessageBody;
+    /**
+     * Indicates that this job is being executed manually
+     *
+     * @var bool
+     */
+    protected $_manualRun = false;
 
     /**
      * Job constructor.
@@ -155,6 +161,25 @@ public function __clone()
         ]);
     }
 
+    /**
+     * @return bool
+     */
+    public function isManualRun(): bool
+    {
+        return $this->_manualRun;
+    }
+
+    /**
+     * @param bool $manualRun
+     * @return self
+     */
+    public function setManualRun(bool $manualRun): self
+    {
+        $this->_manualRun = $manualRun;
+
+        return $this;
+    }
+
     /**
      * @return array
      */

diff --git a/src/Shell/Task/WorkerTask.php b/src/Shell/Task/WorkerTask.php
@@ -59,6 +59,7 @@ public function executeJob(Job $job)
         $this->out(' - Executing job', 1, Shell::VERBOSE);
         $this->djLog(__('Executing: {0}', $job->getId()));
 
+        $job->setManualRun(true);
         $start = microtime(true);
         $response = JobManager::instance()->execute($job, $this->param('force'));
         $this->djLog(__('Done with: {0}', $job->getId()));