async def remove_all_for_connection(
        self, db: AsyncSession, connection_id: UUID, current_user: schemas.User, uow: UnitOfWork
    ) -> list[Sync]:
        """Remove all syncs for a connection.

        Args:
            db (AsyncSession): The database session
            connection_id (UUID): The ID of the connection
            current_user (schemas.User): The current user
            uow (UnitOfWork): The unit of work
        Returns:
            list[Sync]: The removed syncs
        """
        # Use the SyncConnection join table to find all syncs associated with this connection
        stmt = (
            select(Sync)
            .join(SyncConnection, Sync.id == SyncConnection.sync_id)
            .where(SyncConnection.connection_id == connection_id)
            .where(Sync.organization_id == current_user.organization_id)
        )
        result = await db.execute(stmt)
        syncs = result.scalars().unique().all()

        removed_syncs = []
        for sync in syncs:
            removed_sync = await self.remove(db, id=sync.id, current_user=current_user, uow=uow)
            removed_syncs.append(removed_sync)

        return removed_syncs
Remove all syncs for a connection.

        Args:
            db (AsyncSession): The database session
            connection_id (UUID): The ID of the connection
            current_user (schemas.User): The current user
            uow (UnitOfWork): The unit of work
        Returns:
            list[Sync]: The removed syncs
        
backend/airweave/crud/crud_sync.py