sumanthakannantha

@vektah Any updates on this? We are also interested with this feature.

We are facing a similar issue. In flush function, errors are not propagated to individual items using onFailure callback. func (w *worker) flush(ctx context.Context) error { **. . . .**...

Hi Any update on this issue?

+1