An Endless loop happens using parallel_record_records

[workingloong]

If there is an error in record_generator_with_retry, the process to read records cannot stop and always recall record_generator_with_retry. I think the reason is that the exception in the sub-process to read records cannot break the main process. So, we maybe need to determine the status of the sub-process.