CheckJobHealthTask::run() - Code Metrics - Inspection of "WIP: NEW Allowing disabling health checks - adding..." - symbiote/silverstripe-queuedjobs - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#214)

unknown

created 2018-09-04 02:21 UTC

CheckJobHealthTask::run() A

↳ 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			namespace Symbiote\QueuedJobs\Tasks;
3
4			use SilverStripe\Control\HTTPRequest;
5			use SilverStripe\Dev\BuildTask;
6			use Symbiote\QueuedJobs\Services\QueuedJob;
7			use Symbiote\QueuedJobs\Services\QueuedJobService;
8
9			class CheckJobHealthTask extends BuildTask
10			{
11			/**
12			* {@inheritDoc}
13			* @var string
14			*/
15			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...
16
17			/**
18			* {@inheritDoc}
19			* @return string
20			*/
21			public function getDescription()
22			{
23			return _t(
24			__CLASS__ . '.Description',
25			'A task used to check the health of jobs that are "running". Pass a specific queue as the "queue" ' .
26			'parameter or otherwise the "Queued" queue will be checked'
27			);
28			}
29
30			/**
31			* Implement this method in the task subclass to
32			* execute via the TaskRunner
33			*
34			* @param HTTPRequest $request
35			* @return
36			*/
37			public function run($request)
38			{
39			$queue = $request->requestVar('queue') ?: QueuedJob::QUEUED;
40
41			$stalledJobCount = $this->getService()->checkJobHealth($queue);
42
43			echo $stalledJobCount === 0 ? 'All jobs are healthy' : 'Detected and attempted restart on ' . $stalledJobCount .
44			' stalled jobs';
45			}
46
47			protected function getService()
48			{
49			return QueuedJobService::singleton();
50			}
51			}
52

symbiote / silverstripe-queuedjobs

GitHub Access Token became invalid

Pull Request — master (#214)

CheckJobHealthTask::run() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like