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.