Merge branch 'dev' of https://github.com/Dispatcharr/Dispatcharr into pr/stlalpha/488

dispatcharr/celery.py

@@ -50,13 +50,21 @@ app.conf.update(
 )
 
 # Add memory cleanup after task completion
-#@task_postrun.connect  # Use the imported signal
+@task_postrun.connect  # Use the imported signal
 def cleanup_task_memory(**kwargs):
-    """Clean up memory after each task completes"""
+    """Clean up memory and database connections after each task completes"""
+    from django.db import connection
+    
     # Get task name from kwargs
     task_name = kwargs.get('task').name if kwargs.get('task') else ''
 
-    # Only run cleanup for memory-intensive tasks
+    # Close database connection for this Celery worker process
+    try:
+        connection.close()
+    except Exception:
+        pass
+
+    # Only run memory cleanup for memory-intensive tasks
     memory_intensive_tasks = [
         'apps.m3u.tasks.refresh_single_m3u_account',
         'apps.m3u.tasks.refresh_m3u_accounts',

dispatcharr/settings.py

@@ -51,6 +51,11 @@ EPG_BATCH_SIZE = 1000  # Number of records to process in a batch
 EPG_MEMORY_LIMIT = 512  # Memory limit in MB before forcing garbage collection
 EPG_ENABLE_MEMORY_MONITORING = True  # Whether to monitor memory usage during processing
 
+# XtreamCodes Rate Limiting Settings
+# Delay between profile authentications when refreshing multiple profiles
+# This prevents providers from temporarily banning users with many profiles
+XC_PROFILE_REFRESH_DELAY = float(os.environ.get('XC_PROFILE_REFRESH_DELAY', '2.5'))  # seconds between profile refreshes
+
 # Database optimization settings
 DATABASE_STATEMENT_TIMEOUT = 300  # Seconds before timing out long-running queries
 DATABASE_CONN_MAX_AGE = (
@@ -134,6 +139,7 @@ else:
             "PASSWORD": os.environ.get("POSTGRES_PASSWORD", "secret"),
             "HOST": os.environ.get("POSTGRES_HOST", "localhost"),
             "PORT": int(os.environ.get("POSTGRES_PORT", 5432)),
+            "CONN_MAX_AGE": DATABASE_CONN_MAX_AGE,
         }
     }
 
@@ -211,6 +217,10 @@ CELERY_BEAT_SCHEDULE = {
         "task": "core.tasks.scan_and_process_files",  # Direct task call
         "schedule": 20.0,  # Every 20 seconds
     },
+    "maintain-recurring-recordings": {
+        "task": "apps.channels.tasks.maintain_recurring_recordings",
+        "schedule": 3600.0,  # Once an hour ensure recurring schedules stay ahead
+    },
 }
 
 MEDIA_ROOT = BASE_DIR / "media"