From 8b0396ba00a1303ff907bf2729dbef2a6b3116b4 Mon Sep 17 00:00:00 2001 From: zman Date: Fri, 28 Feb 2025 10:12:49 -0500 Subject: [PATCH] a --- app/services/task.py | 4 ++-- app/services/tcgplayer_api.py | 5 ++++- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/app/services/task.py b/app/services/task.py index c1779b4..c6e2eed 100644 --- a/app/services/task.py +++ b/app/services/task.py @@ -26,8 +26,8 @@ class TaskService: def register_scheduled_tasks(self): self.scheduler.add_job(self.hourly_pricing, 'cron', minute='35') - # every 5 hours - self.scheduler.add_job(self.inventory_pricing, 'cron', hour='*/5') + # every 5 hours on the 24th minute + self.scheduler.add_job(self.inventory_pricing, 'cron', hour='*/5', minute='24') self.logger.info("Scheduled tasks registered.") def hourly_pricing(self): diff --git a/app/services/tcgplayer_api.py b/app/services/tcgplayer_api.py index 9e7b2fc..d6e5f30 100644 --- a/app/services/tcgplayer_api.py +++ b/app/services/tcgplayer_api.py @@ -7,6 +7,7 @@ from app.db.utils import db_transaction from sqlalchemy.orm import Session from datetime import datetime from uuid import uuid4 as uuid +import json logger = logging.getLogger(__name__) @@ -159,11 +160,13 @@ class TCGPlayerAPIService: return tcgplayer_pricing.json() def save_tcgplayer_pricing_data(self, product_id: str, pricing_data: dict): + # convert to json + pricing_data_json = json.dumps(pricing_data) with db_transaction(self.db): pricing_record = APIPricing( id=str(uuid()), product_id=product_id, - pricing_data=str(pricing_data) + pricing_data=str(pricing_data_json) ) self.db.add(pricing_record)