Commit 6956f3db authored by Paromita Mitra's avatar Paromita Mitra
Browse files

dask_storage_parameters trial4

parent 5e57ecd7
Pipeline #62648 passed with stage
in 33 seconds
......@@ -7,9 +7,12 @@ from .blob_storage_factory_ibm import IBMBlobStorageFactory
async def get_dask_storage_parameters(tenant: Tenant, directory: Optional[str] = None) -> DaskStorageParameters:
storage = IBMBlobStorageFactory()
access_key = storage._access_key
secret_key = storage._secret_key
endpoint_url = storage._endpointURL
print("minio endpoint url ", endpoint_url)
base_directory = f'{tenant.bucket_name}/{directory}' if directory else tenant.bucket_name
storage_options = {'anon': False, 'use_ssl': True, 'key': storage._access_key, 'secret': storage._secret_key, 'client_kwargs': {'endpoint_url': storage._endpointURL}}
storage_options = {'key': access_key, 'secret': secret_key, 'client_kwargs': {'endpoint_url': endpoint_url}}
return DaskStorageParameters(protocol='https',
base_directory=base_directory,
storage_options=storage_options)
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment