Skip to content
Snippets Groups Projects
Commit 8fc9060e authored by Victor Dosda's avatar Victor Dosda
Browse files

fix missing record id

parent aa400ea2
No related branches found
No related tags found
1 merge request!240Deletion of bulk data
Hide whitespace changes
Inline Side-by-side
app/routers/delete/delete_bulk_data.py
+ 1
− 1
View file @ 8fc9060e
......@@ -96,7 +96,7 @@ async def delete_purge_record(
tenant = await resolve_tenant(ctx.partition_id)
storage: BlobStorageBase = await ctx.app_injector.get(BlobStorageBase)
encode_record_id = dask_blob_storage.encode_record_id()
encode_record_id = dask_blob_storage.encode_record_id(record_id)
bulk_file_names = await storage.list_objects(tenant=tenant,
prefix=encode_record_id)
delete_results = await asyncio.gather(*[storage.delete(tenant=tenant, object_name=bulk_file_name)
......
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