app/workers/wordpress_sync.py

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
    )