Method __call__

dali/python/nvidia/dali/external_source.py:700–971

(
        self,
        *,
        source=None,
        cycle=None,
        name=None,
        layout=None,
        dtype=None,
        ndim=None,
        cuda_stream=None,
        use_copy_kernel=None,
        batch=None,
        parallel=None,
        no_copy=None,
        prefetch_queue_depth=None,
        bytes_per_sample_hint=None,
        batch_info=None,
        repeat_last=False,
        **kwargs,
    )

        return False

    def __call__(
        self,
        *,
        source=None,
        cycle=None,
        name=None,
        layout=None,
        dtype=None,
        ndim=None,
        cuda_stream=None,
        use_copy_kernel=None,
        batch=None,
        parallel=None,
        no_copy=None,
        prefetch_queue_depth=None,
        bytes_per_sample_hint=None,
        batch_info=None,
        repeat_last=False,
        **kwargs,
    ):
        """"""
        from nvidia.dali.ops import _OperatorInstance, _separate_kwargs

        if batch_info is None:
            batch_info = self._batch_info or False
        elif self._batch_info is not None:
            raise ValueError("The argument ``batch_info`` already specified in constructor.")

        if source is None:
            if cycle is not None:
                if self._callback:
                    raise ValueError(
                        "The argument ``cycle`` can only be specified if ``source`` is an"
                        "iterable object or a generator function specified in this call. "
                        "To cycle through an iterable specified in "
                        "``__init__``, set ``cycle`` there."
                    )
                else:
                    raise ValueError(
                        "The argument ``cycle`` can only be specified if ``source`` is a "
                        "reusable iterable or a generator function."
                    )
            callback = self._callback
            source_desc = self._source_desc
        else:
            if self._callback is not None:
                raise RuntimeError("``source`` already specified in constructor.")
            callback, source_desc = _get_callback_from_source(source, cycle, self._batch_info)

            # Keep the metadata for Pipeline inspection
            self._source_desc = source_desc

        if callback is not None and repeat_last:
            raise ValueError(
                f"``repeat_last`` must not be set when using the ``source`` argument "
                f"It's usable only with manually fed `{self._operator_name()}`."
            )