📦 EqualifyEverything / equalify-reflow

📄 queues.py · 28 lines
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28"""Queue name constants for Redis operations.

Defines all queue and key names used for job processing workflow.
All keys use the eq-pdf namespace prefix.
"""

# Redis namespace prefix
REDIS_PREFIX = "eq-pdf"

# Processing queues (Redis Lists)
PII_QUEUE_NAME = f"{REDIS_PREFIX}:queue:pii"
APPROVAL_QUEUE_NAME = f"{REDIS_PREFIX}:queue:approval"
PROCESSING_QUEUE_NAME = f"{REDIS_PREFIX}:queue:processing"

# Short aliases for convenience
PII_QUEUE = PII_QUEUE_NAME
APPROVAL_QUEUE = APPROVAL_QUEUE_NAME
PROCESSING_QUEUE = PROCESSING_QUEUE_NAME

# Timeout tracking (Redis Sorted Sets)
APPROVAL_TIMEOUT_KEY = f"{REDIS_PREFIX}:timeouts:approval"

# Metrics tracking (Redis Hashes)
DAILY_METRICS_KEY = f"{REDIS_PREFIX}:metrics:daily"

# Job status key prefix (Redis Hashes)
JOB_STATUS_KEY_PREFIX = f"{REDIS_PREFIX}:job:"