from app.services.wordpress_sync import process_wordpress_sync_job from app.workers.celery_app import celery_app @celery_app.task def sync_wordpress_site( tenant_id: str, job_id: str, site_url: str, rest_base: str = "posts", force: bool = False ) -> None: process_wordpress_sync_job( tenant_id=tenant_id, job_id=job_id, site_url=site_url, rest_base=rest_base, force=force )