async def _start_sync(self) -> None:
        """Initialize sync job and update status to in-progress."""
        self.sync_context.logger.info(
            f"Starting sync job {self.sync_context.sync_job.id} for sync "
            f"{self.sync_context.sync.id}"
        )

        await sync_job_service.update_status(
            sync_job_id=self.sync_context.sync_job.id,
            status=SyncJobStatus.IN_PROGRESS,
            current_user=self.sync_context.current_user,
            started_at=datetime.now(),
        )
Initialize sync job and update status to in-progress.
backend/airweave/platform/sync/orchestrator.py