revert engine fix

OpenFn · Feb 13, 2025 · 7adaa1a · 7adaa1a
1 parent beb4617
commit 7adaa1a
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 6 deletions.
diff --git a/.changeset/little-ears-work.md b/.changeset/little-ears-work.md
diff --git a/packages/engine-multi/src/worker/thread/run.ts b/packages/engine-multi/src/worker/thread/run.ts
@@ -7,6 +7,8 @@ import type { SanitizePolicies } from '@openfn/logger';
 
 import { register, publish } from './runtime';
 import { execute, createLoggers } from './helpers';
+import serializeError from '../../util/serialize-error';
+import { JobErrorPayload } from '../../events';
 
 export type RunOptions = {
   repoDir: string;
@@ -15,6 +17,13 @@ export type RunOptions = {
   statePropsToRemove?: string[];
 };
 
+const eventMap = {
+  'job-error': (evt: JobErrorPayload) => ({
+    ...evt,
+    error: serializeError(evt.error),
+  }),
+};
+
 register({
   run: (plan: ExecutionPlan, input: State, runOptions: RunOptions) => {
     const { repoDir, whitelist, sanitize, statePropsToRemove } = runOptions;
@@ -52,9 +61,11 @@ register({
         // For now I am preloading credentials
         // resolveCredential: async (id: string) => {},
         notify: (name: NotifyEvents, payload: any) => {
+          // @ts-ignore
+          const mappedPayload = eventMap[name]?.(payload) ?? payload;
           publish(`worker:${name}`, {
             workflowId: plan.id,
-            ...payload,
+            ...mappedPayload,
           });
         },
       },