add console.warn() for all workers process

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,

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,

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,

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,