Setting up schedulers for Jackett feed and background search

api/scheduler.py

@@ -4,10 +4,11 @@ from apscheduler.triggers.cron import CronTrigger
 from db.config import settings
 from mediafusion_scrapy.task import run_spider
 from scrapers.imdb_data import fetch_movie_ids_to_update
-from scrapers.prowlarr_feed import run_prowlarr_feed_scraper
+from scrapers.background_scraper import run_background_search
+from scrapers.feed_scraper import run_prowlarr_feed_scraper, run_jackett_feed_scraper
 from scrapers.trackers import update_torrent_seeders
 from scrapers.tv import validate_tv_streams_in_db
-from scrapers.utils import cleanup_expired_scraper_task
+from scrapers.scraper_tasks import cleanup_expired_scraper_task
 from streaming_providers.cache_helpers import cleanup_expired_cache
 
 
@@ -210,6 +211,16 @@ def setup_scheduler(scheduler: AsyncIOScheduler):
             },
         )
 
+    if not settings.disable_jackett_feed_scraper:
+        scheduler.add_job(
+            run_jackett_feed_scraper.send,
+            CronTrigger.from_crontab(settings.jackett_feed_scraper_crontab),
+            name="jackett_feed_scraper",
+            kwargs={
+                "crontab_expression": settings.jackett_feed_scraper_crontab,
+            },
+        )
+
     scheduler.add_job(
         cleanup_expired_scraper_task.send,
         CronTrigger.from_crontab(settings.cleanup_expired_scraper_task_crontab),
@@ -227,3 +238,10 @@ def setup_scheduler(scheduler: AsyncIOScheduler):
             "crontab_expression": settings.cleanup_expired_cache_task_crontab,
         },
     )
+
+    scheduler.add_job(
+        run_background_search.send,
+        CronTrigger.from_crontab(settings.background_search_crontab),
+        name="background_search",
+        kwargs={"crontab_expression": settings.background_search_crontab},
+    )

db/config.py

@@ -103,6 +103,7 @@ class Settings(BaseSettings):
     jackett_feed_scrape_interval_hour: int = 3
 
     background_search_interval_hours: int = 72
+    background_search_crontab: str = "*/5 * * * *"
 
     # Premiumize Settings
     premiumize_oauth_client_id: str | None = None

scrapers/background_scraper.py

@@ -185,7 +185,7 @@ class BackgroundSearchWorker:
     min_backoff=timedelta(minutes=10),
     max_backoff=timedelta(hours=1),
 )
-async def run_background_search():
+async def run_background_search(**kwargs):
     """Scheduled task to run background searches"""
     from db import database