servicex.minio_adaptor.find_new_bucket_files#

async servicex.minio_adaptor.find_new_bucket_files(adaptor: MinioAdaptor, request_id: str, update: AsyncIterator[Any]) AsyncIterator[str][source]#

Each time we get something from the async iterator, check to see if there are any files present.