diff --git a/odds/backend/processor/dataset_processor.py b/odds/backend/processor/dataset_processor.py index 8813f4f..39a126a 100644 --- a/odds/backend/processor/dataset_processor.py +++ b/odds/backend/processor/dataset_processor.py @@ -36,7 +36,7 @@ async def process(self, dataset: Dataset, catalog: DataCatalog, datasetFilter: D if config.debug: rts.set(ctx, f'PROCESS DATASET {dataset.versions.get('resource_analyzer')} {dataset.title}') resources = self.prune_resources(dataset, ctx) - if await datasetFilter.analyze(datasetFilter): + if await datasetFilter.analyze(dataset): if len(resources) > 0: await asyncio.gather( *[