Mirrors/Dispatcharr
1
0
Fork 1
mirror of https://github.com/Dispatcharr/Dispatcharr.git synced 2026-01-23 02:35:14 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Cleaned up logging.

Browse source
This commit is contained in:
SergeantPanda 2025-05-10 14:13:43 -05:00
parent d5b64a56d6
commit ee8cef5aa9
2 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

4
apps/m3u/tasks.py
View file

@ -840,7 +840,7 @@ def refresh_single_m3u_account(account_id):
try:
logger.info(f"Calling refresh_m3u_groups for account {account_id}")
result = refresh_m3u_groups(account_id, full_refresh=True)
logger.debug(f"refresh_m3u_groups result: {result}")
logger.trace(f"refresh_m3u_groups result: {result}")
# Check for completely empty result or missing groups
if not result or result[1] is None:
@ -1009,7 +1009,7 @@ def refresh_single_m3u_account(account_id):
# Optionally remove completed task from the group to prevent processing it again
result.remove(async_result)
else:
logger.debug(f"Task is still running.")
logger.trace(f"Task is still running.")
# Ensure all database transactions are committed before cleanup
logger.info(f"All {total_batches} tasks completed, ensuring DB transactions are committed before cleanup")

10
dispatcharr/celery.py
View file

@ -55,7 +55,7 @@ def setup_celery_logging(**kwargs):
print(f"Celery configuring loggers with level: {log_level}")
# Get the specific loggers that output potentially noisy messages
for logger_name in ['celery.app.trace', 'celery.beat', 'celery.worker.strategy', 'celery.beat.Scheduler']:
for logger_name in ['celery.app.trace', 'celery.beat', 'celery.worker.strategy', 'celery.beat.Scheduler', 'celery.pool']:
logger = logging.getLogger(logger_name)
# Remove any existing filters first (in case this runs multiple times)
@ -63,9 +63,8 @@ def setup_celery_logging(**kwargs):
if hasattr(filter, '__class__') and filter.__class__.__name__ == 'SuppressFilter':
logger.removeFilter(filter)
# For INFO level - add a filter to hide repetitive messages
# For DEBUG/TRACE level - don't filter (show everything)
if log_level == 'INFO':
# Add filtering for both INFO and DEBUG levels - only TRACE will show full logging
if log_level not in ['TRACE']:
# Add a custom filter to completely filter out the repetitive messages
class SuppressFilter(logging.Filter):
def filter(self, record):
@ -73,7 +72,8 @@ def setup_celery_logging(**kwargs):
if (
"succeeded in" in getattr(record, 'msg', '') or
"Scheduler: Sending due task" in getattr(record, 'msg', '') or
"received" in getattr(record, 'msg', '')
"received" in getattr(record, 'msg', '') or
(logger_name == 'celery.pool' and "Apply" in getattr(record, 'msg', ''))
):
return False # Don't log these messages at all
return True # Log all other messages