From 23a07683fc2e5d4145032f0dc4e79dd930d8f5ac Mon Sep 17 00:00:00 2001 From: mhdzumair Date: Sat, 23 Nov 2024 00:01:57 +0530 Subject: [PATCH] Simplify metrics logging --- scrapers/base_scraper.py | 4 +--- scrapers/prowlarr.py | 20 -------------------- 2 files changed, 1 insertion(+), 23 deletions(-) diff --git a/scrapers/base_scraper.py b/scrapers/base_scraper.py index 40b8b00..ea5bff6 100644 --- a/scrapers/base_scraper.py +++ b/scrapers/base_scraper.py @@ -210,9 +210,7 @@ class ScraperMetrics: lines.extend( [ f" {indexer_name}:", - f" ├─ Results : {stats['results_count']:>6}", - f" ├─ Successes : {stats['success_count']:>6}", - f" └─ Errors : {stats['error_count']:>6}", + f" └─ Results :{stats['results_count']:>6} Successes :{stats['success_count']:>6} Errors :{stats['error_count']:>6}", ] ) diff --git a/scrapers/prowlarr.py b/scrapers/prowlarr.py index 27cdda9..d047279 100644 --- a/scrapers/prowlarr.py +++ b/scrapers/prowlarr.py @@ -151,24 +151,6 @@ class ProwlarrScraper(BaseScraper): ) return self.indexer_circuit_breakers[indexer_id] - async def log_indexer_status(self): - """Log the current status of all indexers and their circuit breakers""" - status_lines = ["Current Indexer Status:"] - - for indexer_id, status in self.indexer_status.items(): - circuit_breaker = self.indexer_circuit_breakers.get(indexer_id) - if circuit_breaker: - cb_status = circuit_breaker.get_status() - status_lines.append( - f"Indexer {status.get('name', f'ID:{indexer_id}')}:\n" - f" Health: {'Healthy' if status.get('is_healthy') else 'Unhealthy'}\n" - f" Circuit Breaker: {cb_status['state']}\n" - f" Failures: {cb_status['failures']}\n" - f" Accepting Requests: {cb_status['is_accepting_requests']}" - ) - - self.logger.info("\n".join(status_lines)) - @BaseScraper.cache(ttl=PROWLARR_SEARCH_TTL) @BaseScraper.rate_limit(calls=5, period=timedelta(seconds=1)) async def _scrape_and_parse( @@ -1046,7 +1028,6 @@ async def background_movie_title_search( # Log final metrics and indexer status scraper.metrics.stop() scraper.metrics.log_summary(scraper.logger) - await scraper.log_indexer_status() scraper.logger.info( f"Background title search completed for {metadata.title} ({metadata.year})" @@ -1143,7 +1124,6 @@ async def background_series_title_search( # Log final metrics and indexer status scraper.metrics.stop() scraper.metrics.log_summary(scraper.logger) - await scraper.log_indexer_status() scraper.logger.info( f"Background title search completed for {metadata.title} S{season}E{episode}"