diff --git a/src/server/jobs/importZetkinDataSources.ts b/src/server/jobs/importZetkinDataSources.ts index 455cf9952..7f933d481 100644 --- a/src/server/jobs/importZetkinDataSources.ts +++ b/src/server/jobs/importZetkinDataSources.ts @@ -17,6 +17,18 @@ const importZetkinDataSources = async (): Promise => { ); continue; } + if (source.autoEnrich && source.enrichments.length > 0) { + try { + await enqueue("enrichDataSource", source.id, { + dataSourceId: source.id, + }); + } catch (error) { + logger.warn( + `Failed to enqueue enrichment for Zetkin data source ${source.id}`, + { error }, + ); + } + } } return true; };