8844450205

Committed 26 Apr 2024 07:06AM UTC coverage: 53.409% (-0.04%) from 53.447%

Build # 8844450205

Build Type

push

github

Committed by

jpmckinney

Commit Message

Revert "chore: Use self.stdout and self.stderr instead of logger, in management command"

This reverts commit e69f59bdd.

manageprocess is run by cron, so should log instead of stdout, in this case (which causes emails)

Run Details

0 of 4 new or added lines in 1 file covered. (0.0%)

1 existing line in 1 file now uncovered.

752 of 1408 relevant lines covered (53.41%)

0.53 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/data_registry/management/commands/manageprocess.py

import logging

from django.core.management.base import BaseCommand

from data_registry.exceptions import RecoverableException
from data_registry.models import Collection, Job
from data_registry.process_manager import get_task_manager, process

logger = logging.getLogger(__name__)


class Command(BaseCommand):
    help = "Orchestrate and evaluate all jobs and tasks"

    def handle(self, *args, **options):
        for collection in Collection.objects.all():
            process(collection)

        # Complete jobs, whose temporary data is not deleted or to be preserved.
        for job in Job.objects.prefetch_related("task_set").complete().filter(archived=False, keep_all_data=False):
            for task in job.task_set.all():
                task_manager = get_task_manager(task)
                if not task_manager.final_output:
                    try:
                        task_manager.wipe()
                    except RecoverableException:
                        logger.exception("Recoverable exception when wiping task %s for job %s", task, job)
                        break
            else:
                job.archived = True
                job.save()
                logger.info("Job %s wiped", job)

NEW 1	import logging	×
2
UNCOV 3	from django.core.management.base import BaseCommand	×
4
5	from data_registry.exceptions import RecoverableException	×
6	from data_registry.models import Collection, Job	×
7	from data_registry.process_manager import get_task_manager, process	×
8
NEW 9	logger = logging.getLogger(__name__)	×
10
11
12	class Command(BaseCommand):	×
13	help = "Orchestrate and evaluate all jobs and tasks"	×
14
15	def handle(self, args, *options):	×
16	for collection in Collection.objects.all():	×
17	process(collection)	×
18
19	# Complete jobs, whose temporary data is not deleted or to be preserved.
20	for job in Job.objects.prefetch_related("task_set").complete().filter(archived=False, keep_all_data=False):	×
21	for task in job.task_set.all():	×
22	task_manager = get_task_manager(task)	×
23	if not task_manager.final_output:	×
24	try:	×
25	task_manager.wipe()	×
26	except RecoverableException:	×
NEW 27	logger.exception("Recoverable exception when wiping task %s for job %s", task, job)	×
28	break	×
29	else:
30	job.archived = True	×
31	job.save()	×
NEW 32	logger.info("Job %s wiped", job)	×

open-contracting / data-registry / 8844450205

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous