Commit 824efe20 authored by Cyril Monmouton's avatar Cyril Monmouton
Browse files

Restore code

parent 869d8f5e
Pipeline #50108 failed with stages
in 13 minutes and 31 seconds
......@@ -282,10 +282,9 @@ async def get_data_version(
# fallback on ddms_v2 Persistence for wks:log schema
bulk_id, prefix = LogBulkHelper.get_bulk_id(record, None)
if bulk_id is None:
raise BulkNotFound(record_id=record_id, bulk_id=None)
try:
if bulk_id is None:
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)
elif prefix is None:
......
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