CancelException with AsyncBulkLoad (Python helper)

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.

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.