@mrshenli I tried the solution with the cleaner thread and it doesn’t work:
seems like the wait() in the cleaner thread stops the whole process.
I think this is were its at in code. 3
I could only make it work with
while not r.is_completed():
    pass

but performance suffered a lot (~2x slowdown) compared my previous solution.