servicex.servicex_adaptor.transform_status_stream

async servicex.servicex_adaptor.transform_status_stream(sa: ServiceXAdaptor, client: ClientSession, request_id: str) → AsyncIterator[Tuple[Optional[int], int, Optional[int]]]

Returns an async stream of (files-remaining, files_processed, files_failed) until the servicex request_id request is finished, against the servicex instance located at sa.

Arguments:

sa The servicex low level adaptor client An async http function we can call and use request_id The request id for this request

Returns:

remaining, processed, skipped Returns an async stream triple of the

status numbers. Every time we find something we send it on.

Note: