inngest - npm Package Compare versions

Comparing version 2.4.2-pr-294.2 to 2.4.2-pr-294.3

components/InngestExecution.d.ts

@@ -123,2 +123,8 @@ import { type Simplify } from "type-fest";
     /**
+     * A flag which represents whether or not steps are understood to be used in
+     * this function. This is used to determine whether or not we should run
+     * some steps (such as `step.sendEvent`) inline as they are found.
+     */
+    hasSteps: boolean;
+    /**
      * The core loop - a generator used to take an action upon finding the next
@@ -125,0 +131,0 @@ * checkpoint. Manages the flow of execution and cleaning up after itself.

components/InngestExecution.js

@@ -376,2 +376,3 @@ "use strict";
         loop,
+        hasSteps: Boolean(Object.keys(stepState).length),
         setCheckpoint: (checkpoint) => {
@@ -378,0 +379,0 @@ ({ promise: checkpointPromise, resolve: checkpointResolve } =

components/InngestStepTools.js

@@ -57,2 +57,5 @@ "use strict";
             var _a, _b, _c, _d;
+            if (!state.hasSteps && (opts === null || opts === void 0 ? void 0 : opts.nonStepExecuteInline) && opts.fn) {
+                return Promise.resolve(opts.fn(...args));
+            }
             if (state.executingStep) {
@@ -79,2 +82,3 @@ /**
             const step = (state.steps[opId.id] = Object.assign(Object.assign({}, opId), { fn: (opts === null || opts === void 0 ? void 0 : opts.fn) ? () => { var _a; return (_a = opts.fn) === null || _a === void 0 ? void 0 : _a.call(opts, ...args); } : undefined, fulfilled: Boolean(state.stepState[opId.id]) }));
+            state.hasSteps = true;
             pushStepToReport(step);
@@ -81,0 +85,0 @@ const stepState = state.stepState[opId.id];

package.json

 {
   "name": "inngest",
-  "version": "2.4.2-pr-294.2",
+  "version": "2.4.2-pr-294.3",
   "description": "Official SDK for Inngest.com",
@@ -5,0 +5,0 @@ "main": "./index.js",

version.d.ts

@@ -1,2 +0,2 @@
-export declare const version = "2.4.2-pr-294.2";
+export declare const version = "2.4.2-pr-294.3";
 //# sourceMappingURL=version.d.ts.map

version.js

@@ -5,3 +5,3 @@ "use strict";
 // Generated by genversion.
-exports.version = "2.4.2-pr-294.2";
+exports.version = "2.4.2-pr-294.3";
 //# sourceMappingURL=version.js.map

No alert changes

Improved metrics

Total package byte prevSize

507450

increased by0.17%

Lines of code

7760

increased by0.14%

No dependency changes