servicex.servicex_adaptor.trap_servicex_failures#

async servicex.servicex_adaptor.trap_servicex_failures(stream: AsyncIterator[Tuple[Optional[int], int, Optional[int]]]) → AsyncIterator[Tuple[Optional[int], int, Optional[int]]][source]#: Looks for any failed files. If it catches one, it will remember it and throw once the stream is done. This allows all the files to come down first.