From 13d2e4adeb1f351955956ba85f985a6381a25edd Mon Sep 17 00:00:00 2001 From: counterweight Date: Mon, 22 Dec 2025 16:10:13 +0100 Subject: [PATCH] refactor: move JOB_FETCH_BITCOIN_PRICE constant to worker.py Unlike JOB_RANDOM_NUMBER which is used for external job enqueueing, JOB_FETCH_BITCOIN_PRICE is only used internally by the scheduler. Move it to worker.py to clarify it's not part of the public job API. --- backend/jobs.py | 1 - backend/worker.py | 5 ++++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/backend/jobs.py b/backend/jobs.py index 50862f4..ac88276 100644 --- a/backend/jobs.py +++ b/backend/jobs.py @@ -10,7 +10,6 @@ from database import ASYNCPG_DATABASE_URL # Job type constants JOB_RANDOM_NUMBER = "random_number" -JOB_FETCH_BITCOIN_PRICE = "fetch_bitcoin_price" # Connection pool for job enqueueing (lazy initialized) _pool: asyncpg.Pool | None = None diff --git a/backend/worker.py b/backend/worker.py index 83f5cb0..2bc436e 100644 --- a/backend/worker.py +++ b/backend/worker.py @@ -13,9 +13,12 @@ from pgqueuer.models import Schedule from pgqueuer.queries import Queries from database import ASYNCPG_DATABASE_URL -from jobs import JOB_FETCH_BITCOIN_PRICE, JOB_RANDOM_NUMBER +from jobs import JOB_RANDOM_NUMBER from price_fetcher import PAIR_BTC_EUR, SOURCE_BITFINEX, fetch_btc_eur_price +# Scheduled job type (internal to worker, not enqueued externally) +JOB_FETCH_BITCOIN_PRICE = "fetch_bitcoin_price" + logging.basicConfig( level=logging.INFO, format="%(asctime)s - %(name)s - %(levelname)s - %(message)s",