src/Job/BaseJob.php

@@ -6,8 +6,11 @@ use Cron\CronExpression;
 use GO\Job;
 use GO\Scheduler;
 use Logger;
+use MTi\Application\SystemMisconfiguredException;
 use MTi\IDatetime;
 use MTi\IEnv;
+use Nette\IOException;
+use Nette\Utils\FileSystem;
 
 
 abstract class BaseJob
@@ -52,7 +55,15 @@ abstract class BaseJob
             $job = $this->_sched->php($this->_script, NULL, $params, $id);
             $job->before([$this, 'before'])->then([$this, 'after'])->at($cron->getExpression());
             if ($this->isLocking()) {
-                $job->onlyOne($this->env()->cacheDir() . '/scheduler');
+                $lockDir = $this->env()->cacheDir() . '/scheduler';
+                if (!is_dir($lockDir)) {
+                    try {
+                        FileSystem::createDir($lockDir);
+                    } catch (IOException $e) {
+                        throw new SystemMisconfiguredException('Cannot create job locking directory!');
+                    }
+                }
+                $job->onlyOne($lockDir);
             }
             return $job;
         }