@openfn/engine-multi - npm Package Compare versions

Comparing version 0.1.9 to 0.1.10

CHANGELOG.md

 # engine-multi
 
+## 0.1.10
+
+### Patch Changes
+
+- c8e9d51: Forward next from job complete
+- Updated dependencies [7f352d2]
+  - @openfn/runtime@0.1.3
+
 ## 0.1.9
@@ -4,0 +12,0 @@

dist/index.d.ts

@@ -53,2 +53,3 @@ import * as _openfn_logger from '@openfn/logger';
     state: any;
+    next: string[];
 }
@@ -60,2 +61,3 @@ interface JobErrorPayload extends ExternalEvent {
     error: any;
+    next: string[];
 }
@@ -62,0 +64,0 @@ interface WorkerLogPayload extends ExternalEvent, JSONLog {

dist/index.js

@@ -166,4 +166,2 @@ // src/api.ts
           const duration = Date.now() - startTime;
-          console.log("AUTOINSTALL ERROR");
-          console.log(e);
           context.emit(AUTOINSTALL_ERROR, {
@@ -325,3 +323,2 @@ module: name,
   logger.success("complete workflow ", workflowId);
-  logger.info(state);
   state.status = "done";
@@ -344,3 +341,3 @@ state.result = result;
 var jobComplete = (context, event) => {
-  const { threadId, state, duration, jobId } = event;
+  const { threadId, state, duration, jobId, next } = event;
   context.emit(JOB_COMPLETE, {
@@ -350,7 +347,8 @@ threadId,
     duration,
-    jobId
+    jobId,
+    next
   });
 };
 var jobError = (context, event) => {
-  const { threadId, state, error: error2, duration, jobId } = event;
+  const { threadId, state, error: error2, duration, jobId, next } = event;
   context.emit(JOB_ERROR, {
@@ -361,3 +359,4 @@ threadId,
     duration,
-    jobId
+    jobId,
+    next
   });
@@ -364,0 +363,0 @@ };

dist/worker/mock.js

@@ -107,3 +107,4 @@ // src/worker/mock-worker.ts
         duration: 100,
-        state
+        state,
+        next: []
       });
@@ -110,0 +111,0 @@ resolve(state);

package.json

 {
   "name": "@openfn/engine-multi",
-  "version": "0.1.9",
+  "version": "0.1.10",
   "description": "Multi-process runtime engine",
@@ -14,3 +14,3 @@ "main": "dist/index.js",
     "@openfn/logger": "0.0.19",
-    "@openfn/runtime": "0.1.2"
+    "@openfn/runtime": "0.1.3"
   },
@@ -17,0 +17,0 @@ "devDependencies": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

39315

increased by0.33%

Lines of code

1059

increased by0.19%

Dependency changes

• + Added@openfn/runtime@0.1.3(transitive)

• - Removed@openfn/runtime@0.1.2(transitive)

• Updated@openfn/runtime@0.1.3