boboldehampsink /
taskmanager
| @@ 26-40 (lines=15) @@ | ||
| 23 | Craft::log(Craft::t('Running new tasks.')); |
|
| 24 | ||
| 25 | // Make sure tasks aren't already running |
|
| 26 | if (!craft()->tasks->isTaskRunning()) { |
|
| 27 | ||
| 28 | // Is there a pending task? |
|
| 29 | if (craft()->tasks->getNextPendingTask()) { |
|
| 30 | ||
| 31 | // Start running tasks |
|
| 32 | craft()->tasks->runPendingTasks(); |
|
| 33 | ||
| 34 | return 1; |
|
| 35 | } else { |
|
| 36 | Craft::log(Craft::t('No pending tasks found.')); |
|
| 37 | } |
|
| 38 | } else { |
|
| 39 | Craft::log(Craft::t('Tasks are already running.')); |
|
| 40 | } |
|
| 41 | ||
| 42 | return 0; |
|
| 43 | } |
|
| @@ 56-71 (lines=16) @@ | ||
| 53 | while (true) { |
|
| 54 | ||
| 55 | // Make sure tasks aren't already running |
|
| 56 | if (!craft()->tasks->isTaskRunning()) { |
|
| 57 | ||
| 58 | // Reset next pending tasks cache |
|
| 59 | $this->resetCraftNextPendingTasksCache(); |
|
| 60 | ||
| 61 | // Is there a pending task? |
|
| 62 | if (craft()->tasks->getNextPendingTask()) { |
|
| 63 | ||
| 64 | // Start running tasks |
|
| 65 | craft()->tasks->runPendingTasks(); |
|
| 66 | } else { |
|
| 67 | Craft::log(Craft::t('No pending tasks found.')); |
|
| 68 | } |
|
| 69 | } else { |
|
| 70 | Craft::log(Craft::t('Tasks are already running, skipping iteration.')); |
|
| 71 | } |
|
| 72 | ||
| 73 | // Sleep a little |
|
| 74 | sleep(10); |
|
