Clear loading errors

whiletrue-industries · Jun 12, 2024 · 4ff5302 · 4ff5302
1 parent 6960819
commit 4ff5302
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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