@the-libs/redis-backend - npm Package Compare versions

Comparing version 1.21.160 to 1.22.3

package.json

 {
   "name": "@the-libs/redis-backend",
-  "version": "1.21.160",
+  "version": "1.22.3",
   "scripts": {
@@ -8,3 +8,3 @@ "update": "npx --yes npm-check-updates -u"
   "dependencies": {
-    "@the-libs/base-shared": "^1.21.159",
+    "@the-libs/base-shared": "^1.21.160",
     "@bull-board/express": "^6.7.10",
@@ -11,0 +11,0 @@ "redlock": "^5.0.0-beta.2",

src/services/bull/distributedByStagesQeuues.d.ts

@@ -23,3 +23,4 @@ import { PubSub } from '../pubsub';
 export declare const runStageAsService: <StagesEnum extends Record<string, string>, Stage extends keyof StagesEnum, InputMap extends Record<keyof StagesEnum, Record<string, unknown>>, StageIOMapping extends InferStageIOMapping<StagesEnum, InputMap>>({ stages, stage, service, }: StageServiceConfig<StagesEnum, Stage, InputMap, StageIOMapping>, pubsub?: PubSub, STAGE_UPDATES_CHANNEL?: string) => import("bull").Queue<BaseJob<StagesEnum, StageIOMapping, Stage, InputMap>>;
-export declare const startOrchestratedJob: <StagesEnum extends Record<string, string>, InputMap extends Record<keyof StagesEnum, Record<string, unknown>>, FirstStage extends keyof StagesEnum, StageIOMapping extends InferStageIOMapping<StagesEnum, InputMap>>(stages: StagesEnum, firstStageInput: StageIOMapping[FirstStage]["Input"], service: (taskData: BaseJob<StagesEnum, StageIOMapping, FirstStage, InputMap>["stageData"]) => Promise<StageIOMapping[FirstStage]["Output"]>, pubsub?: PubSub, STAGE_UPDATES_CHANNEL?: string) => Promise<import("bull").Job<{
+export declare const startOrchestratedJob: <StagesEnum extends Record<string, string>, InputMap extends Record<keyof StagesEnum, Record<string, unknown>>, FirstStage extends keyof StagesEnum, StageIOMapping extends InferStageIOMapping<StagesEnum, InputMap>>(stages: StagesEnum, firstStageInput: StageIOMapping[FirstStage]["Input"], // First stage input
+service: (taskData: BaseJob<StagesEnum, StageIOMapping, FirstStage, InputMap>["stageData"]) => Promise<StageIOMapping[FirstStage]["Output"]>, pubsub?: PubSub, STAGE_UPDATES_CHANNEL?: string) => Promise<import("bull").Job<{
     runId: unknown;
@@ -26,0 +27,0 @@ currentStage: FirstStage;

No alert changes

Improved metrics

Total package byte prevSize

55842

0.76%

Dependency changes

• Updated

  @the-libs/base-shared@^1.21.160