def _recursive_search()

in torchdata/datapipes/iter/util/cacheholder.py [0:0]

• 9 lines of code
• 5 McCabe index (conditional complexity)

    def _recursive_search(graph):
        for dp in graph.keys():
            # Find the closest CacheHolder
            if isinstance(dp, OnDiskCacheHolderIterDataPipe):
                return dp
        for dp in graph.values():
            res = EndOnDiskCacheHolderIterDataPipe._recursive_search(dp)
            if res is not None:
                return res
        return None