0c0a424004
- Remove Skyvern service + DB from docker-compose.yml
- Remove cron/browser_executor.py and pipelines/steps/skyvern.py
- Remove browser_scrape from cron executor dispatch
- Update tests to reflect Skyvern removal
- Fix test_needs_query_rewrite false positive ('das' is a valid trigger)
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
27 lines
733 B
Python
27 lines
733 B
Python
"""Dispatch cron jobs to the correct executor by job_type."""
|
|
|
|
import logging
|
|
|
|
from .brave_search import execute_brave_search
|
|
from .reminder import execute_reminder
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
EXECUTORS = {
|
|
"brave_search": execute_brave_search,
|
|
"reminder": execute_reminder,
|
|
}
|
|
|
|
|
|
async def execute_job(job: dict, send_text, matrix_client) -> dict:
|
|
"""Execute a cron job and return a result dict for reporting."""
|
|
job_type = job["jobType"]
|
|
executor = EXECUTORS.get(job_type)
|
|
|
|
if not executor:
|
|
msg = f"Unknown job type: {job_type}"
|
|
logger.error(msg)
|
|
return {"status": "error", "error": msg}
|
|
|
|
return await executor(job=job, send_text=send_text, matrix_client=matrix_client)
|