Delete users data incrementally

Author: seanh

h/models/job.py

@@ -28,6 +28,8 @@
    that really need Postgres transactionality should use this custom job queue.
 """
 
+from enum import Enum
+
 from sqlalchemy import (
     Column,
     DateTime,
@@ -47,6 +49,11 @@
 class Job(Base):
     """A job in the job queue."""
 
+    class JobName(str, Enum):
+        SYNC_ANNOTATION = "sync_annotation"
+        ANNOTATION_SLIM = "annotation_slim"
+        PURGE_USER = "purge_user"
+
     __tablename__ = "job"
 
     __table_args__ = (Index("ix__job_priority_enqueued_at", "priority", "enqueued_at"),)

h/services/job_queue.py

@@ -1,5 +1,4 @@
 from datetime import datetime, timedelta
-from enum import Enum
 
 from sqlalchemy import and_, func, literal_column, select
 from zope.sqlalchemy import mark_changed
@@ -15,10 +14,6 @@ class Priority:
 
 
 class JobQueueService:
-    class JobName(str, Enum):
-        SYNC_ANNOTATION = "sync_annotation"
-        ANNOTATION_SLIM = "annotation_slim"
-
     def __init__(self, db):
         self._db = db