Commit 4f5ac687 authored by Anuj Gupta's avatar Anuj Gupta
Browse files

Merge branch 'Bulk_Data_API_Impl' into 'master'

Bulk data api impl

See merge request !169
parents 5ad788c3 44c641ce
Pipeline #51992 failed with stages
in 24 minutes and 43 seconds
......@@ -6,6 +6,7 @@ from app.utils import Context
from .app_injector import AppInjector, AppInjectorModule
from app.bulk_persistence import resolve_tenant
from app.bulk_persistence.dask.dask_bulk_storage import DaskBulkStorage
from osdu_ibm.storage.dask_storage_parameters import get_dask_storage_parameters as ibm_parameters
class IBMInjector(AppInjectorModule):
......@@ -25,4 +26,8 @@ class IBMInjector(AppInjectorModule):
@staticmethod
async def build_ibm_dask_blob_storage() -> DaskBulkStorage:
raise NotImplementedError()
# raise NotImplementedError()
ctx: Context = Context.current()
tenant = await resolve_tenant(ctx.partition_id)
params = await ibm_parameters(tenant)
return await DaskBulkStorage.create(params)
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