def queue_operation(
        self,
        **kwargs: Any,
    ) -> DelegatedOperationDocument:
        """Queue an operation to be executed by a delegated operator."""
        raise NotImplementedError("subclass must implement queue_operation()")
Queue an operation to be executed by a delegated operator.
fiftyone/factory/repos/delegated_operation.py