CheckJobHealthTask::run() - Code Metrics - symbiote/silverstripe-queuedjobs - Measure and Improve Code Quality continuously with Scrutinizer

CheckJobHealthTask::run() A
last analyzed 2019-12-18 20:39 UTC

↳ Parent: CheckJobHealthTask

Complexity

Conditions	3
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	9
rs	9.9666
c	0
b	0
f	0
cc	3
nc	2
nop	1

<?php

namespace Symbiote\QueuedJobs\Tasks;

use SilverStripe\Control\HTTPRequest;
use SilverStripe\Dev\BuildTask;
use Symbiote\QueuedJobs\Services\QueuedJob;
use Symbiote\QueuedJobs\Services\QueuedJobService;

class CheckJobHealthTask extends BuildTask
{
    /**
     * {@inheritDoc}
     * @var string
     */
    private static $segment = 'CheckJobHealthTask';


    /**
     * {@inheritDoc}
     * @return string
     */
    public function getDescription()
    {
        return _t(
            __CLASS__ . '.Description',
            'A task used to check the health of jobs that are "running". Pass a specific queue as the "queue" ' .
            'parameter or otherwise the "Queued" queue will be checked'
        );
    }

    /**
     * Implement this method in the task subclass to
     * execute via the TaskRunner
     *
     * @param HTTPRequest $request
     * @return
     */
    public function run($request)
    {
        $queue = $request->requestVar('queue') ?: QueuedJob::QUEUED;

        $stalledJobCount = $this->getService()->checkJobHealth($queue);

        echo $stalledJobCount === 0 ? 'All jobs are healthy' : 'Detected and attempted restart on ' . $stalledJobCount .
            ' stalled jobs';
    }

    protected function getService()
    {
        return QueuedJobService::singleton();
    }
}


1			<?php
2
3			namespace Symbiote\QueuedJobs\Tasks;
4
5			use SilverStripe\Control\HTTPRequest;
6			use SilverStripe\Dev\BuildTask;
7			use Symbiote\QueuedJobs\Services\QueuedJob;
8			use Symbiote\QueuedJobs\Services\QueuedJobService;
9
10			class CheckJobHealthTask extends BuildTask
11			{
12			/**
13			* {@inheritDoc}
14			* @var string
15			*/
16			private static $segment = 'CheckJobHealthTask';
			0 ignored issues – show Comprehensibility introduced 2018-09-04 01:34 UTC by Report Bug Copy Issue Report Consider using a different property name as you override a private property of the parent class. Loading history...
17
18			/**
19			* {@inheritDoc}
20			* @return string
21			*/
22			public function getDescription()
23			{
24			return _t(
25			__CLASS__ . '.Description',
26			'A task used to check the health of jobs that are "running". Pass a specific queue as the "queue" ' .
27			'parameter or otherwise the "Queued" queue will be checked'
28			);
29			}
30
31			/**
32			* Implement this method in the task subclass to
33			* execute via the TaskRunner
34			*
35			* @param HTTPRequest $request
36			* @return
37			*/
38			public function run($request)
39			{
40			$queue = $request->requestVar('queue') ?: QueuedJob::QUEUED;
41
42			$stalledJobCount = $this->getService()->checkJobHealth($queue);
43
44			echo $stalledJobCount === 0 ? 'All jobs are healthy' : 'Detected and attempted restart on ' . $stalledJobCount .
45			' stalled jobs';
46			}
47
48			protected function getService()
49			{
50			return QueuedJobService::singleton();
51			}
52			}
53

symbiote / silverstripe-queuedjobs

GitHub Access Token became invalid

CheckJobHealthTask::run() A last analyzed 2019-12-18 20:39 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

CheckJobHealthTask::run() A
last analyzed 2019-12-18 20:39 UTC