Commit 6b1aa1f1 authored by Luc Yriarte's avatar Luc Yriarte
Browse files

Process request params also when reading v2 bulks

parent 5f627034
Pipeline #49117 failed with stages
in 11 minutes and 53 seconds
......@@ -281,12 +281,11 @@ async def get_data_version(
raise BulkNotFound(record_id=record_id, bulk_id=None)
if prefix == BULK_URN_PREFIX_VERSION:
df = await dask_blob_storage.load_bulk(record_id, bulk_id)
df = await DataFrameRender.process_params(df, ctrl_p)
elif prefix is None:
df = await get_dataframe(ctx, bulk_id)
else:
raise BulkNotFound(record_id=record_id, bulk_id=bulk_id)
df = await DataFrameRender.process_params(df, ctrl_p)
return await DataFrameRender.df_render(df, ctrl_p, request.headers.get('Accept'))
except BulkError as ex:
ex.raise_as_http()
......
Supports Markdown
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