engine: Include timestamp on JOB_ERROR

integration-tests/worker/CHANGELOG.md

@@ -1,5 +1,14 @@
 # @openfn/integration-tests-worker
 
+## 1.0.62
+
+### Patch Changes
+
+- Updated dependencies [ae55a6a]
+  - @openfn/[email protected]
+  - @openfn/[email protected]
+  - @openfn/[email protected]
+
 ## 1.0.61
 
 ### Patch Changes

integration-tests/worker/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@openfn/integration-tests-worker",
   "private": true,
-  "version": "1.0.61",
+  "version": "1.0.62",
   "description": "Lightning WOrker integration tests",
   "author": "Open Function Group <[email protected]>",
   "license": "ISC",

packages/engine-multi/CHANGELOG.md

@@ -1,5 +1,11 @@
 # engine-multi
 
+## 1.3.0
+
+### Minor Changes
+
+- ae55a6a: Include timestamp on JOB_ERROR payload
+
 ## 1.2.5
 
 ### Patch Changes

packages/engine-multi/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openfn/engine-multi",
-  "version": "1.2.5",
+  "version": "1.3.0",
   "description": "Multi-process runtime engine",
   "main": "dist/index.js",
   "type": "module",

packages/engine-multi/src/api/lifecycle.ts

@@ -120,6 +120,7 @@ export const jobError = (
     duration,
     jobId,
     next,
+    time: timestamp(),
   });
 };
 

packages/engine-multi/src/events.ts

@@ -86,6 +86,7 @@ export interface JobCompletePayload extends ExternalEvent {
 export interface JobErrorPayload extends ExternalEvent {
   jobId: string;
   duration: number;
+  time: bigint;
   state: any; // the result state
   error: any;
   next: string[]; // downstream jobs

packages/engine-multi/test/api/lifecycle.test.ts

@@ -9,6 +9,7 @@ import {
   jobStart,
   jobComplete,
   error,
+  jobError,
 } from '../../src/api/lifecycle';
 import { WorkflowState } from '../../src/types';
 import ExecutionContext from '../../src/classes/ExecutionContext';
@@ -194,6 +195,49 @@ test(`job-complete: emits ${e.JOB_COMPLETE} with key fields`, (t) => {
   });
 });
 
+test(`job-error: emits ${e.JOB_ERROR} with key fields`, (t) => {
+  return new Promise((done) => {
+    const workflowId = 'a';
+
+    const state = {
+      id: workflowId,
+      startTime: Date.now() - 1000,
+    } as WorkflowState;
+
+    const context = createContext(workflowId, state);
+
+    const event: w.JobErrorEvent = {
+      type: w.JOB_ERROR,
+      error: {
+        message: 'Unexpected content returned',
+        name: 'JobError',
+        severity: 'fail',
+      },
+      workflowId,
+      threadId: '1',
+      jobId: 'j',
+      duration: 2,
+      state: 22,
+      next: [],
+    };
+
+    context.on(e.JOB_ERROR, (evt) => {
+      t.is(evt.workflowId, workflowId);
+      t.is(evt.threadId, '1');
+      t.is(evt.jobId, 'j');
+      t.is(evt.state, 22);
+      t.is(evt.duration, 2);
+      t.deepEqual(evt.next, []);
+      t.deepEqual(evt.error, event.error);
+      t.assert(evt.time > 0);
+      t.assert(typeof evt.time === 'bigint');
+      done();
+    });
+
+    jobError(context, event);
+  });
+});
+
 test(`log: emits ${e.WORKFLOW_LOG}`, (t) => {
   return new Promise((done) => {
     const workflowId = 'a';

packages/lightning-mock/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @openfn/lightning-mock
 
+## 2.0.20
+
+### Patch Changes
+
+- Updated dependencies [ae55a6a]
+  - @openfn/[email protected]
+
 ## 2.0.19
 
 ### Patch Changes

packages/lightning-mock/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openfn/lightning-mock",
-  "version": "2.0.19",
+  "version": "2.0.20",
   "private": true,
   "description": "A mock Lightning server",
   "main": "dist/index.js",

packages/ws-worker/CHANGELOG.md

@@ -1,5 +1,16 @@
 # ws-worker
 
+## 1.7.0
+
+### Minor Changes
+
+- ae55a6a: Include timestamp on step complete even if the step failed
+
+### Patch Changes
+
+- Updated dependencies [ae55a6a]
+  - @openfn/[email protected]
+
 ## 1.6.7
 
 ### Patch Changes

packages/ws-worker/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openfn/ws-worker",
-  "version": "1.6.7",
+  "version": "1.7.0",
   "description": "A Websocket Worker to connect Lightning to a Runtime Engine",
   "main": "dist/index.js",
   "type": "module",