def METHOD_NAME(cls, node: Subtask):
    from ...core.operand import Fetch, FetchShuffle
    for node in node.chunk_graph:
        if isinstance(node.op, (Fetch, FetchShuffle)):
            continue
        yield node.op