diff --git a/django_cron/cron.py b/django_cron/cron.py index 8d65f49..4b28f12 100644 --- a/django_cron/cron.py +++ b/django_cron/cron.py @@ -25,9 +25,13 @@ def do(self): settings, 'FAILED_RUNS_CRONJOB_EMAIL_PREFIX', '' ) + min_num_failures_default = getattr( + settings, 'DJANGO_CRON_MIN_NUM_FAILURES_DEFAULT', 10 + ) + for cron in crons_to_check: - min_failures = getattr(cron, 'MIN_NUM_FAILURES', 10) + min_failures = getattr(cron, 'MIN_NUM_FAILURES', min_num_failures_default) jobs = CronJobLog.objects.filter(code=cron.code).order_by('-end_time')[ :min_failures ]