diff --git a/src/api/services/enrichment/enrichment.js b/src/api/services/enrichment/enrichment.js index 083304aaf..cb788a662 100644 --- a/src/api/services/enrichment/enrichment.js +++ b/src/api/services/enrichment/enrichment.js @@ -400,6 +400,8 @@ export const setEnrichmentError = async (ctx, err) => { }); jobLogger.info(ctx.job, logData); notifyListeners(room, logData); + // very useful for identifying the origin of production errors. + console.warn('handleEnrichmentError', err); notifyListeners(`${ctx.tenant}-enricher`, { isEnriching: false, success: false, diff --git a/src/api/services/precomputed/precomputed.js b/src/api/services/precomputed/precomputed.js index c82137e4d..08e7779b6 100644 --- a/src/api/services/precomputed/precomputed.js +++ b/src/api/services/precomputed/precomputed.js @@ -531,6 +531,7 @@ export const setPrecomputedError = async (ctx, err) => { progress.finish(ctx.tenant); jobLogger.info(ctx.job, logData); notifyListeners(room, logData); + console.warn('handlePrecomputedError', err); notifyListeners(`${ctx.tenant}-precomputer`, { isPrecomputing: false, success: false, diff --git a/src/api/workers/import.js b/src/api/workers/import.js index c4ae2c8b6..65bd3238d 100644 --- a/src/api/workers/import.js +++ b/src/api/workers/import.js @@ -58,6 +58,8 @@ const handleImportError = async (job, err) => { if (err instanceof CancelWorkerError) { await ctx.dataset.drop(); } + // very useful for identifying the origin of production errors. + console.warn('handleImportError', err); notifyListeners(`${job.data.tenant}-import`, { isImporting: false, success: false, diff --git a/src/api/workers/publisher.js b/src/api/workers/publisher.js index 6da85eb42..9392a166f 100644 --- a/src/api/workers/publisher.js +++ b/src/api/workers/publisher.js @@ -39,6 +39,8 @@ const startPublishing = async (job) => { const handlePublishError = async (job, error) => { const ctx = await prepareContext({ job }); await clearPublished(ctx); + // very useful for identifying the origin of production errors. + console.warn('handlePublisherError', error); notifyListeners(`${job.data.tenant}-publisher`, { isPublishing: false, success: false,