SyncIntervalHandler.check() - Code Metrics - Inspection of "Fixed an issue where accounts would be named "admi..." - fuzeman/Plex-Trakt-Scrobbler - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — develop ( e15ceb...5f9839 )

by Dean

created 2016-06-26 22:59 UTC

SyncIntervalHandler.check() A

↳ Parent: SyncIntervalHandler

Complexity

Conditions

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	20

Importance

Changes

Metric	Value
dl	0
loc	20
ccs	0
cts	11
cp	0
rs	9.2
c	0
b	0
f	0
cc	4
crap	20

from plugin.models import SyncResult
from plugin.modules.scheduler.handlers.core.base import Handler
from plugin.preferences.options import SyncIntervalOption
from plugin.sync.core.enums import SyncMode
from plugin.sync.core.exceptions import QueueError
from plugin.sync.main import Sync

from datetime import datetime
import logging

log = logging.getLogger(__name__)


class SyncIntervalHandler(Handler):
    key = 'sync.interval'

    def check(self, job):
        last_result = SyncIntervalOption.get_last_result(job.account, SyncMode.Full)

        if last_result is None or last_result.started_at <= job.due_at:
            return True

        # Re-schedule job
        job.due_at = job.next_at(last_result.started_at)

        log.debug('Job re-scheduled to %r', job.due_at)

        # Check if a trigger is required
        if job.due_at <= datetime.utcnow():
            return True

        # Trigger ignored, update job
        job.save()

        log.debug('Ignoring scheduled sync interval (already triggered)')
        return False

    def run(self, job):
        # Ensure sync hasn't already been triggered
        if not self.check(job):
            return False

        try:
            # Queue sync
            Sync.queue(
                account=job.account,
                mode=SyncMode.Full,

                priority=100,
                trigger=SyncResult.Trigger.Schedule
            )
        except QueueError, ex:
            log.info('Queue error: %s', ex)
        except Exception, ex:
            log.error('Unable to queue sync: %s', ex, exc_info=True)

        return True


1			from plugin.models import SyncResult
2			from plugin.modules.scheduler.handlers.core.base import Handler
3			from plugin.preferences.options import SyncIntervalOption
4			from plugin.sync.core.enums import SyncMode
5			from plugin.sync.core.exceptions import QueueError
6			from plugin.sync.main import Sync
7
8			from datetime import datetime
9			import logging
10
11			log = logging.getLogger(__name__)
12
13
14			class SyncIntervalHandler(Handler):
15			key = 'sync.interval'
16
17			def check(self, job):
18			last_result = SyncIntervalOption.get_last_result(job.account, SyncMode.Full)
19
20			if last_result is None or last_result.started_at <= job.due_at:
21			return True
22
23			# Re-schedule job
24			job.due_at = job.next_at(last_result.started_at)
25
26			log.debug('Job re-scheduled to %r', job.due_at)
27
28			# Check if a trigger is required
29			if job.due_at <= datetime.utcnow():
30			return True
31
32			# Trigger ignored, update job
33			job.save()
34
35			log.debug('Ignoring scheduled sync interval (already triggered)')
36			return False
37
38			def run(self, job):
39			# Ensure sync hasn't already been triggered
40			if not self.check(job):
41			return False
42
43			try:
44			# Queue sync
45			Sync.queue(
46			account=job.account,
47			mode=SyncMode.Full,
48
49			priority=100,
50			trigger=SyncResult.Trigger.Schedule
51			)
52			except QueueError, ex:
53			log.info('Queue error: %s', ex)
54			except Exception, ex:
55			log.error('Unable to queue sync: %s', ex, exc_info=True)
56
57			return True
58

fuzeman / Plex-Trakt-Scrobbler

Push — develop ( e15ceb...5f9839 )

SyncIntervalHandler.check() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like