counterweight/arbret
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

refactor: use JOB_RANDOM_NUMBER constant instead of magic string in worker

Browse source
This commit is contained in:
counterweight 2025-12-21 23:23:46 +01:00
parent 027a6fb64c
commit ca97ff1aa8
Signed by: counterweight
GPG key ID: 883EDBAA726BD96C
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
backend/worker.py
View file

@ -12,6 +12,7 @@ from pgqueuer.db import AsyncpgDriver
from pgqueuer.queries import Queries from pgqueuer.queries import Queries
from database import ASYNCPG_DATABASE_URL from database import ASYNCPG_DATABASE_URL
from jobs import JOB_RANDOM_NUMBER
logging.basicConfig( logging.basicConfig(
level=logging.INFO, level=logging.INFO,
@ -85,7 +86,7 @@ async def process_random_number_job(job: Job, db_pool: asyncpg.Pool) -> None:
def register_job_handlers(qm: QueueManager, db_pool: asyncpg.Pool) -> None: def register_job_handlers(qm: QueueManager, db_pool: asyncpg.Pool) -> None:
"""Register all job handlers with the queue manager.""" """Register all job handlers with the queue manager."""
@qm.entrypoint("random_number") @qm.entrypoint(JOB_RANDOM_NUMBER)
async def handle_random_number(job: Job) -> None: async def handle_random_number(job: Job) -> None:
"""Handle random_number job entrypoint.""" """Handle random_number job entrypoint."""
await process_random_number_job(job, db_pool) await process_random_number_job(job, db_pool)