Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(7)  |  Call(6)  |  Derive(0)  |  Import(1)

src/d/a/DAGPype-0.1.5.1/dagpype/_subgroup_filt.py   DAGPype(Download)
import types
 
from dagpype._core import filters, sub_pipe_target
from dagpype._snk import to_list
from dagpype._filt import filt
                    cur_k = k
                    pipe = key_pipe(k)
                    sub_target = sub_pipe_target(pipe, target)
                try:
                    sub_target.send(e)
                k = key(e)
                if k not in targets:
                    targets[k] = sub_pipe_target(key_pipe(k), target)
                    pipes.append(targets[k])
                # Tmp - make sub_pipe_target have this.
                k = (yield)
                pipe = key_pipe(k)
                sub_pipe_target(pipe, target)
        except GeneratorExit:
            target.close()
    def _dagpype_internal_fn_act(target):
        if out_of_dict_pipe is not None:
            out_of_dict_target = sub_pipe_target(out_of_dict_pipe, target)
        else:
            out_of_dict_target = None