[Feature Request] Kill the entire pipeline if input iterator raises an exception

[renxinhe]

Is your feature request related to a problem? Please describe.
In all the examples, the input is a simple, hardcoded list (e.g. [1, 2, 3]). In my case, my input function is an iterator function that may raise an exception during an arbitrary iteration. In that case, I'd like pypeln to invalidate the entire pipeline's work, and propagate the exception and optionally offer a way to do some clean up.

Describe the solution you'd like

import pypeln

def input_func():
    for i in range(10):
        if i < 7:
            yield i
        else:
            raise Exception()

def compute_func():
    # some arbitrary operation
    pass

try:
     encryption_stage = pl.process.each(
            compute_func,
            input_func,
            run=True,
    )
except Exception e:
     # allows me to handle input_func error here

Describe alternatives you've considered
A clear and concise description of any alternative solutions or features you've considered, any example in any other framework

Additional context
#63 describes a way to handle error if compute_func throws an exception. Currently I don't see a way for pypeln to raise the exception raised by input_func. Can anyone see a good workaround for this issue as well? Thanks!