Skip to content

Commit

Permalink
FEATURE/#165
Browse files Browse the repository at this point in the history
  • Loading branch information
joocer committed Jun 4, 2022
1 parent a68b246 commit 8119c93
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
2 changes: 1 addition & 1 deletion opteryx/storage/adapters/blob/minio_store.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@


class MinIoStorage(BaseStorageAdapter):

def __init__(self, end_point: str, access_key: str, secret_key: str, **kwargs):

if not minio_installed: # pragma: no cover
Expand All @@ -39,6 +38,7 @@ def get_blob_list(self, partition):

def read_blob(self, blob_name):
import io

try:
bucket, object_path, name, extension = paths.get_parts(blob_name)
stream = self.minio.get_object(bucket, object_path + name + extension)
Expand Down
4 changes: 3 additions & 1 deletion tests/storage/test_minio_storage.py
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,9 @@ def test_minio_storage():

populate_minio()

storage = MinIoStorage(end_point=END_POINT, access_key=SECRETS, secret_key=SECRETS, secure=False)
storage = MinIoStorage(
end_point=END_POINT, access_key=SECRETS, secret_key=SECRETS, secure=False
)
conn = opteryx.connect(reader=storage, partition_scheme=None)

# SELECT EVERYTHING
Expand Down

0 comments on commit 8119c93

Please sign in to comment.