Skip to content
Snippets Groups Projects
Commit ecc4cc73 authored by antondmtvch's avatar antondmtvch
Browse files

fix uploader

parent 493b6173
No related branches found
No related tags found
No related merge requests found
......@@ -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,
)
......
......@@ -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',
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment