async def get_all_with_schedule(self, db: AsyncSession) -> list[schemas.SyncWithoutConnections]:
        """Get all syncs with a schedule that are due to run.

        Returns:
            list[schemas.SyncWithoutConnections]: The syncs without connections
        """
        now = datetime.now(timezone.utc)
        stmt = select(Sync).where(
            (Sync.status == SyncStatus.ACTIVE)
            & (Sync.cron_schedule.is_not(None))
            & ((Sync.next_scheduled_run <= now) | (Sync.next_scheduled_run.is_(None)))
        )
        result = await db.execute(stmt)
        syncs = result.scalars().unique().all()

        return [schemas.SyncWithoutConnections.model_validate(sync) for sync in syncs]
Get all syncs with a schedule that are due to run.

        Returns:
            list[schemas.SyncWithoutConnections]: The syncs without connections
        
backend/airweave/crud/crud_sync.py