diff --git a/perxis/files/uploader.py b/perxis/files/uploader.py index d066401d62c0e6740b268796300fe8556d240b42..3d7117eca3fb23751ee46927522d09f6d5d81542 100644 --- a/perxis/files/uploader.py +++ b/perxis/files/uploader.py @@ -20,7 +20,6 @@ async def read_chunks( if not data: break yield data - file_object.seek(0) class FileUploader: @@ -30,8 +29,8 @@ class FileUploader: data_provider: PerxisDataProvider, chunk_size: int = DEFAULT_CHUNK_SIZE, ) -> None: - self._file_provider = file_provider - self._data_provider = data_provider + self.file_provider = file_provider + self.data_provider = data_provider self.chunk_size = chunk_size async def __put_chunks( @@ -60,7 +59,7 @@ class FileUploader: file_size: int, collection_id: str ) -> items_pb2.CreateResponse: - message = await self._file_provider.start_upload( + message = await self.file_provider.start_upload( file_name=file_name, file_size=file_size, ) @@ -70,7 +69,7 @@ class FileUploader: part_urls=message.upload.part_urls, ) - await self._file_provider.complete_upload( + await self.file_provider.complete_upload( file_id=message.upload.file.id, upload_id=message.upload.upload_id, parts=parts, @@ -86,7 +85,7 @@ class FileUploader: "file": file, }) - message = await self._data_provider.create( + message = await self.data_provider.create( data=data, collection_id=collection_id, ) @@ -105,7 +104,7 @@ class FileUploader: file_size=file_size, collection_id=collection_id, ) - await self._data_provider.publish( + await self.data_provider.publish( item_id=message.created.id, collection_id=collection_id, ) diff --git a/setup.py b/setup.py index 1e8e0fa25eeda720b5b4fe2c8dc77a4080f0da94..3bb8d079e9996a0558b5877fdbb5f59cee35b30c 100644 --- a/setup.py +++ b/setup.py @@ -14,7 +14,7 @@ def load_requirements(): setup( name='perxis', - version='1.2.1', + version='1.2.2', description='Perxis python client', long_description=long_description, long_description_content_type='text/markdown',