def _expand_subpipe_resolve_incoming(self, node, sub_pipe):
        for inedge in node.incoming():
            for link in inedge._links:
                self._expand_subpipe_resolve_incoming_edge(
                    inedge, link, sub_pipe
                )
Find incoming edges from the sub pipe node that link
dataset/ETHPy150Open thasso/pyjip/jip/pipelines.py/Pipeline._expand_subpipe_resolve_incoming