From 4ff530274b4e0f043f542c0aeb19117368146e88 Mon Sep 17 00:00:00 2001 From: Adam Kariv Date: Wed, 12 Jun 2024 11:43:26 +0300 Subject: [PATCH] Clear loading errors --- odds/backend/processor/resource_processor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/odds/backend/processor/resource_processor.py b/odds/backend/processor/resource_processor.py index 4d181fa..c9ea966 100644 --- a/odds/backend/processor/resource_processor.py +++ b/odds/backend/processor/resource_processor.py @@ -131,7 +131,7 @@ async def process(self, resource: Resource, dataset: Dataset, catalog: DataCatal rts.set(ctx, f'DOWNLOADED {report} BYTES from {resource.url} to {filename}') rts.set(ctx, f'DOWNLOADED {total_size} BYTES from {resource.url} to {filename}') - dp = await asyncio.to_thread(self.load_data, ctx, filename, stream) + dp = await asyncio.to_thread(self.validate_data, ctx, filename, stream) potential_fields = [ Field(name=field['name'], data_type=field['type']) for field in