Hello! I have a little action generator, actually a bunch of coroutines I stich together with aiostream.merge(). I pass it into the AsyncBulkLoad. I haven't reproduced the behavior when I have a small number of test actions, but when I do a real load, it blows up with a CancelException.
My current theory is that the aiostream Streamer throws this exception at the end of its iteration, scotching the load of the last few hundred actions.
Does that sound credible? I do call async_bulk_load in the Streamer's context.