Method from_callback

dali/test/python/test_pool.py:64–68

(
        cls, callback, batch=False, prefetch_queue_depth=1, bytes_per_sample_hint=None
    )

    @classmethod
    def from_callback(
        cls, callback, batch=False, prefetch_queue_depth=1, bytes_per_sample_hint=None
    ):
        _, source_desc = get_callback_from_source(callback, cycle=None)
        return cls(source_desc, batch, prefetch_queue_depth, bytes_per_sample_hint)


def create_pool(groups, keep_alive_queue_size=1, num_workers=1, start_method="fork"):