exceptions from generators shouldn't be silently ignored

[OriHoch]

reproduction

from dataflows import Flow, printer

def generator():
  for i in range(5):
    raise Exception()
    yield {"i": i}

Flow(generator(), printer()).process()

Expected

Exception

Actual

no exception, empty resource

[OriHoch]

related to inferring schema, moving exception below the yield raises it

from dataflows import Flow, printer

def generator():
  for i in range(5):
    yield {"i": i}
    raise Exception()

Flow(generator(), printer()).process()

[akariv]

Interesting find!
Are you looking into it?

[OriHoch]

not at the moment (probably not anytime soon)

[akariv]

👍 assigning to me then