- {% if job.latest %}
- {% if job.latest.status == "success" %}
-
ok
- {% elif job.latest.status == "failure" %}
-
error
+
+ {% if not job.enabled %}
+ paused
+ {% elif job.latest %}
+ {% if job.latest.status == "success" %}
+ ok
+ {% elif job.latest.status == "failure" %}
+ error
+ {% else %}
+ running
+ {% endif %}
{% else %}
- running
+ never run
{% endif %}
- {% else %}
- never run
- {% endif %}
+
{# flex-1 here so the paragraph absorbs whatever space a shorter description leaves, keeping the schedule pill pinned to the bottom of the content block across every card in the row instead of drifting with description length. #}
@@ -55,7 +59,7 @@
{% if job.runs|length > 1 %}
-
+
Recent runs
{% for run in job.runs|slice:":5" %}
@@ -71,6 +75,17 @@
{% endfor %}
{% endif %}
+
+
+
+
{% endfor %}
diff --git a/controlpanel/tests.py b/controlpanel/tests.py
index 8b70dbe..d8c9186 100644
--- a/controlpanel/tests.py
+++ b/controlpanel/tests.py
@@ -22,7 +22,7 @@ from billing.services import BillingError
from billing.services.dues import record_payment, start_trial, subscribe, waive
from club.models import Club, ClubMembership, ClubRole, Season
from events.models import Attendance, Competition, Event, Location
-from features.models import Maintenance
+from features.models import JobToggle, Maintenance
from members.models import Member
from shop.models import Order
from teams.models import Position, StaffAssignment, Team, TeamMembership
@@ -331,6 +331,61 @@ class ClubHomeLocationTests(ControlPanelTestBase):
self.assertFalse(Location.objects.filter(club=self.club, is_home=True).exists())
+class JobToggleViewTests(ControlPanelTestBase):
+ """Pausing/resuming one scheduled platform job -- see controlpanel.views.
+ JobToggleView and features.models.JobToggle."""
+
+ JOB_NAME = "events.tasks.extend_event_series"
+
+ def setUp(self):
+ super().setUp()
+ # JobToggle's cache isn't rolled back with the test transaction.
+ cache.clear()
+ self.addCleanup(cache.clear)
+
+ def toggle(self, name=JOB_NAME):
+ return self.client.post(reverse("controlpanel:job_toggle", args=[name]))
+
+ def test_a_job_starts_enabled(self):
+ response = self.client.get(reverse("controlpanel:jobs"))
+
+ self.assertContains(response, "Pause job")
+
+ def test_pausing_a_job(self):
+ response = self.toggle()
+
+ self.assertRedirects(response, reverse("controlpanel:jobs"))
+ self.assertFalse(JobToggle.is_enabled(self.JOB_NAME))
+
+ def test_resuming_a_paused_job(self):
+ self.toggle()
+
+ self.toggle()
+
+ self.assertTrue(JobToggle.is_enabled(self.JOB_NAME))
+
+ def test_the_jobs_page_reflects_the_paused_state(self):
+ self.toggle()
+
+ response = self.client.get(reverse("controlpanel:jobs"))
+
+ self.assertContains(response, "paused")
+ self.assertContains(response, "Resume job")
+
+ def test_an_unknown_job_name_is_a_404(self):
+ response = self.toggle(name="not.a.real.job")
+
+ self.assertEqual(response.status_code, 404)
+
+ def test_a_non_staff_user_cannot_toggle_a_job(self):
+ self.client.force_login(User.objects.create_user(email="plain-jobs@example.com", password="pw-secret-123"))
+
+ response = self.toggle()
+
+ self.assertEqual(response.status_code, 403)
+ self.assertTrue(JobToggle.is_enabled(self.JOB_NAME))
+
+
class StatisticsTests(TestCase):
@classmethod
def setUpTestData(cls):
diff --git a/controlpanel/urls.py b/controlpanel/urls.py
index 6b9aefd..6147308 100644
--- a/controlpanel/urls.py
+++ b/controlpanel/urls.py
@@ -43,6 +43,7 @@ urlpatterns = [
path("admins/add/", views.PlatformAdminAddView.as_view(), name="admin_add"),
path("admins/
/update/", views.PlatformAdminUpdateView.as_view(), name="admin_update"),
path("admins//revoke/", views.PlatformAdminRevokeView.as_view(), name="admin_revoke"),
- # Jobs (Celery Beat's scheduled platform jobs -- monitoring only, see controlpanel/services/jobs.py)
+ # Jobs (Celery Beat's scheduled platform jobs -- see controlpanel/services/jobs.py)
path("jobs/", views.JobsView.as_view(), name="jobs"),
+ path("jobs//toggle/", views.JobToggleView.as_view(), name="job_toggle"),
]
diff --git a/controlpanel/views.py b/controlpanel/views.py
index 0ec7999..e440b8c 100644
--- a/controlpanel/views.py
+++ b/controlpanel/views.py
@@ -2,7 +2,7 @@ from contextlib import contextmanager
from django.contrib.auth import get_user_model
from django.db.models import Count
-from django.http import HttpResponse
+from django.http import Http404, HttpResponse
from django.shortcuts import get_object_or_404, redirect
from django.urls import reverse
from django.utils import timezone
@@ -19,7 +19,8 @@ from billing.services.invoices import invoice_pdf, issue_invoice
from billing.services.plans import delete_plan, plan_deletion_impact
from club.models import Club, ClubRole
from events.models import Competition, Location
-from features.models import Maintenance
+from features.jobs import JOB_REGISTRY
+from features.models import JobToggle, Maintenance
from .forms import ClubAdminForm, ClubForm, CompetitionForm, DuePaymentForm, FlagForm, HomeLocationForm, MaintenanceForm, OpenPeriodForm, PlanForm, PlanPriceForm, PlatformAdminForm, SubscriptionForm, TrialForm
from .messages import notify
@@ -76,9 +77,10 @@ class DashboardView(PlatformStaffRequiredMixin, TemplateView):
class JobsView(PlatformStaffRequiredMixin, TemplateView):
"""Status and recent history of the scheduled platform jobs -- see features/jobs.py for
- the registry and features/models.JobRun for what a Celery task run writes. Monitoring
- only, deliberately: these run on Celery Beat's own schedule (rosterchief/settings.py),
- not on demand from here."""
+ the registry and features/models.JobRun for what a Celery task run writes. These still
+ run on Celery Beat's own schedule (rosterchief/settings.py) -- there is no "run now"
+ here -- but each one can be paused/resumed individually via JobToggleView below, without
+ reaching for the platform-wide Maintenance lock."""
template_name = "controlpanel/jobs.html"
@@ -86,6 +88,27 @@ class JobsView(PlatformStaffRequiredMixin, TemplateView):
return super().get_context_data(nav="jobs", jobs=job_overview(), **kwargs)
+class JobToggleView(PlatformStaffRequiredMixin, View):
+ """Pause or resume one scheduled job -- see features.models.JobToggle. `name` is the
+ job's dotted Celery task name (a features.jobs.JOB_REGISTRY key), not a database id: a
+ toggle row only exists once a job has actually been flipped off at least once."""
+
+ def post(self, request, name):
+ if name not in JOB_REGISTRY:
+ raise Http404
+
+ enabled = not JobToggle.is_enabled(name)
+ JobToggle.set_enabled(name, enabled)
+
+ label = JOB_REGISTRY[name]["label"]
+ if enabled:
+ notify(request, f"s|Job resumed|“{label}” will run on its schedule again.")
+ else:
+ notify(request, f"w|Job paused|“{label}” will stand down until resumed.")
+
+ return redirect("controlpanel:jobs")
+
+
class ClubListView(PlatformStaffRequiredMixin, ListView):
template_name = "controlpanel/club_list.html"
context_object_name = "clubs"
diff --git a/events/tasks.py b/events/tasks.py
index b05ccb2..452d55a 100644
--- a/events/tasks.py
+++ b/events/tasks.py
@@ -12,7 +12,7 @@ from django.utils.translation import gettext as _
from events.models import Attendance, Event, EventSeries, Lineup
from events.services import generate_occurrences, horizon
from events.services.lineup import publish_lineup
-from features.models import Maintenance
+from features.models import JobToggle, Maintenance
from members.models import Member
from notifications.services import notify_members
@@ -28,6 +28,8 @@ def extend_event_series():
# how a rolling horizon quietly runs dry. Raising here is what turns it into a
# Failure on the control panel's Jobs tab instead of nothing happening at all.
raise RuntimeError("Platform is in maintenance mode; this job stood down.")
+ if not JobToggle.is_enabled("events.tasks.extend_event_series"):
+ raise RuntimeError("This job is disabled in the control panel.")
until = horizon()
total = 0
@@ -85,6 +87,8 @@ def send_deadline_reminders():
"""
if Maintenance.is_on():
raise RuntimeError("Platform is in maintenance mode; this job stood down.")
+ if not JobToggle.is_enabled("events.tasks.send_deadline_reminders"):
+ raise RuntimeError("This job is disabled in the control panel.")
now = timezone.now()
events_reminded = 0
@@ -127,6 +131,8 @@ def publish_scheduled_lineups():
to it, not up to a day late."""
if Maintenance.is_on():
raise RuntimeError("Platform is in maintenance mode; this job stood down.")
+ if not JobToggle.is_enabled("events.tasks.publish_scheduled_lineups"):
+ raise RuntimeError("This job is disabled in the control panel.")
due = Lineup.objects.filter(published_at__isnull=True, scheduled_publish_at__isnull=False, scheduled_publish_at__lte=timezone.now())
count = 0
diff --git a/events/tests.py b/events/tests.py
index f0edd69..f1bb4e8 100644
--- a/events/tests.py
+++ b/events/tests.py
@@ -13,7 +13,7 @@ from waffle import get_waffle_flag_model
from club.models import Club, ClubMembership, OnboardingRequirement, Season
from club.services.onboarding import mark_bypassed, mark_complete
-from features.models import Maintenance
+from features.models import JobToggle, Maintenance
from members.models import Group, GroupMembership, Member
from notifications.models import Notification
from teams.models import Position, RefereeLevel, RefereeProfile, StaffAssignment, Team, TeamMembership
@@ -1981,6 +1981,12 @@ class SendDeadlineRemindersTests(EventsTestBase):
with self.assertRaises(RuntimeError):
send_deadline_reminders()
+ def test_raises_when_paused_from_the_control_panel(self):
+ JobToggle.set_enabled("events.tasks.send_deadline_reminders", False)
+
+ with self.assertRaises(RuntimeError):
+ send_deadline_reminders()
+
class PublishScheduledLineupsTests(EventsTestBase):
"""events.tasks.publish_scheduled_lineups -- the periodic sweep behind a
@@ -2047,3 +2053,9 @@ class PublishScheduledLineupsTests(EventsTestBase):
with self.assertRaises(RuntimeError):
publish_scheduled_lineups()
+
+ def test_raises_when_paused_from_the_control_panel(self):
+ JobToggle.set_enabled("events.tasks.publish_scheduled_lineups", False)
+
+ with self.assertRaises(RuntimeError):
+ publish_scheduled_lineups()
diff --git a/features/migrations/0004_jobtoggle.py b/features/migrations/0004_jobtoggle.py
new file mode 100644
index 0000000..594c5e3
--- /dev/null
+++ b/features/migrations/0004_jobtoggle.py
@@ -0,0 +1,28 @@
+# Generated by Django 6.0.6 on 2026-08-23 09:09
+
+import uuid
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+ dependencies = [
+ ('features', '0003_jobrun'),
+ ]
+
+ operations = [
+ migrations.CreateModel(
+ name='JobToggle',
+ fields=[
+ ('created', models.DateTimeField(auto_now_add=True, verbose_name='created')),
+ ('modified', models.DateTimeField(auto_now=True, verbose_name='modified')),
+ ('id', models.UUIDField(default=uuid.uuid4, editable=False, primary_key=True, serialize=False)),
+ ('name', models.CharField(help_text='Dotted Celery task name, matching a features.jobs.JOB_REGISTRY key.', max_length=255, unique=True, verbose_name='job name')),
+ ('enabled', models.BooleanField(default=True, verbose_name='enabled')),
+ ],
+ options={
+ 'verbose_name': 'job toggle',
+ 'verbose_name_plural': 'job toggles',
+ },
+ ),
+ ]
diff --git a/features/models.py b/features/models.py
index 234cec2..0c44ac4 100644
--- a/features/models.py
+++ b/features/models.py
@@ -153,6 +153,56 @@ class Maintenance(UUIDModel):
return maintenance
+class JobToggle(UUIDModel):
+ """Per-job on/off switch for the scheduled platform jobs in features/jobs.py's
+ JOB_REGISTRY, so the control panel can pause one specific job (a runaway task, one
+ under investigation, ...) without touching Celery Beat's schedule or reaching for
+ the platform-wide Maintenance lock, which stands down every job at once.
+
+ One row per job that's ever been toggled off; a job with no row here is enabled --
+ same "absence means default" shape as Maintenance's own singleton, but keyed instead
+ of a single row, since there's one of these per registry entry rather than one for
+ the whole platform. Cached the same write-through way for the same reason: a flip
+ made in the control panel has to reach every Celery worker, not just the process
+ that made it.
+ """
+
+ CACHE_KEY = "job_toggle:%s"
+ CACHE_SECONDS = 10
+
+ name = models.CharField(_("job name"), max_length=255, unique=True, help_text=_("Dotted Celery task name, matching a features.jobs.JOB_REGISTRY key."))
+ enabled = models.BooleanField(_("enabled"), default=True)
+
+ class Meta:
+ verbose_name = _("job toggle")
+ verbose_name_plural = _("job toggles")
+
+ def __str__(self):
+ return f"{self.name} ({'on' if self.enabled else 'off'})"
+
+ def save(self, *args, **kwargs):
+ super().save(*args, **kwargs)
+ get_cache().set(self.CACHE_KEY % self.name, self.enabled, self.CACHE_SECONDS)
+
+ @classmethod
+ def is_enabled(cls, name: str) -> bool:
+ cache_key = cls.CACHE_KEY % name
+ cached = get_cache().get(cache_key)
+ if cached is not None:
+ return cached
+
+ toggle = cls.objects.filter(name=name).first()
+ enabled = toggle is None or toggle.enabled
+ get_cache().set(cache_key, enabled, cls.CACHE_SECONDS)
+
+ return enabled
+
+ @classmethod
+ def set_enabled(cls, name: str, enabled: bool) -> JobToggle:
+ toggle, _created = cls.objects.update_or_create(name=name, defaults={"enabled": enabled})
+ return toggle
+
+
class JobRun(UUIDModel):
"""One execution of a scheduled platform job -- see features/jobs.py for the registry
of what each job is, and rosterchief/settings.CELERY_BEAT_SCHEDULE for when it runs.
diff --git a/features/tests.py b/features/tests.py
index 97c0e8a..32007fe 100644
--- a/features/tests.py
+++ b/features/tests.py
@@ -13,7 +13,7 @@ from waffle import flag_is_active, get_waffle_flag_model
from club.models import Club
from .jobs import JOB_REGISTRY
-from .models import JobRun, Maintenance
+from .models import JobRun, JobToggle, Maintenance
Flag = get_waffle_flag_model()
User = get_user_model()
@@ -322,3 +322,34 @@ class JobRunTests(TestCase):
self.untracked_task.apply()
self.assertFalse(JobRun.objects.filter(name="features.tests.untracked").exists())
+
+
+class JobToggleTests(TestCase):
+ """Per-job pause/resume switch -- see features.models.JobToggle and its use in
+ events/billing/club's scheduled tasks (each checks JobToggle.is_enabled(name)
+ right alongside the existing Maintenance.is_on() gate)."""
+
+ def setUp(self):
+ # Same reasoning as MaintenanceModeTests -- the toggle's cache isn't
+ # rolled back with the test transaction.
+ cache.clear()
+ self.addCleanup(cache.clear)
+
+ def test_a_job_with_no_row_is_enabled_by_default(self):
+ self.assertTrue(JobToggle.is_enabled("events.tasks.extend_event_series"))
+
+ def test_disabling_a_job(self):
+ JobToggle.set_enabled("events.tasks.extend_event_series", False)
+
+ self.assertFalse(JobToggle.is_enabled("events.tasks.extend_event_series"))
+
+ def test_re_enabling_a_job(self):
+ JobToggle.set_enabled("events.tasks.extend_event_series", False)
+ JobToggle.set_enabled("events.tasks.extend_event_series", True)
+
+ self.assertTrue(JobToggle.is_enabled("events.tasks.extend_event_series"))
+
+ def test_toggling_one_job_does_not_affect_another(self):
+ JobToggle.set_enabled("events.tasks.extend_event_series", False)
+
+ self.assertTrue(JobToggle.is_enabled("events.tasks.send_deadline_reminders"))
diff --git a/management/templates/management/_nav_items.html b/management/templates/management/_nav_items.html
index c9d8246..26dc845 100644
--- a/management/templates/management/_nav_items.html
+++ b/management/templates/management/_nav_items.html
@@ -34,12 +34,13 @@
{% trans "Groups" %}
{% comment %}
Placeholder -- nothing else is built yet (see ARCHITECTURE.md §5.8 and
- management.views.EvaluationsComingSoonView). Deliberately not behind a
- waffle flag like Forms below -- this is a standing "not built yet"
- reminder, so it stays visible rather than disappearing until someone
- remembers to flip a flag on.
+ management.views.EvaluationsComingSoonView). Gated on forms_enabled,
+ same as Forms below: the design (ARCHITECTURE.md §5.8) reuses formbuilder
+ underneath, so a club without that flag shouldn't see it either.
{% endcomment %}
- {% trans "Evaluations" %} {% trans "Soon" %}
+ {% if forms_enabled %}
+ {% trans "Evaluations" %} {% trans "Soon" %}
+ {% endif %}
{% endif %}
{% endif %}
diff --git a/management/templates/management/position_list.html b/management/templates/management/position_list.html
index 88d7355..a563fe0 100644
--- a/management/templates/management/position_list.html
+++ b/management/templates/management/position_list.html
@@ -1,5 +1,5 @@
{% extends "management/base.html" %}
-{% load i18n lucide %}
+{% load i18n lucide ui %}
{% block heading %}{% trans "Positions" %}{% endblock heading %}
@@ -40,7 +40,10 @@