def _expand_always()

in src/chug/wds/filters.py [0:0]

• 15 lines of code
• 6 McCabe index (conditional complexity)

def _expand_always(data, f, handler=wds.reraise_exception):
    for sample in itertools.chain(*data):
        assert isinstance(sample, Mapping)
        try:
            result = f(sample)
        except Exception as exn:
            if handler(exn):
                continue
            else:
                break
        if result is None:
            continue
        if "__key__" in sample:
            result["__key__"] = sample["__key__"]
        yield result