diff --git a/app/services/pricing.py b/app/services/pricing.py index 3fe919d..107e46a 100644 --- a/app/services/pricing.py +++ b/app/services/pricing.py @@ -94,7 +94,7 @@ class PricingService: def cron_load_prices(self, file: File = None): file_content = self.get_pricing_export_content(file) - self.tcgplayer_service.load_tcgplayer_cards(file) + self.tcgplayer_service.load_tcgplayer_cards(file_content) self.load_pricing_csv_content_to_db(file_content) def get_all_prices_for_products(self, product_ids: List[str]) -> Dict[str, Dict[str, float]]: diff --git a/app/services/tcgplayer.py b/app/services/tcgplayer.py index d87c863..a583c60 100644 --- a/app/services/tcgplayer.py +++ b/app/services/tcgplayer.py @@ -499,16 +499,10 @@ class TCGPlayerService: except SQLAlchemyError as e: raise RuntimeError(f"Failed to retrieve group IDs: {str(e)}") - def load_tcgplayer_cards(self) -> File: + def load_tcgplayer_cards(self, file_content): try: - # Get pricing export - export_csv_file = self.get_pricing_export_for_all_products() - export_csv = self.file_service.get_file_content(export_csv_file.id) - # load to card tcgplayer - self.load_export_csv_to_card_tcgplayer(export_csv, export_csv_file.id) - - return export_csv_file + self.load_export_csv_to_card_tcgplayer(file_content) except Exception as e: logger.error(f"Failed to load prices: {e}")