@lage-run/scheduler - npm Package Compare versions

Comparing version 0.7.1 to 0.7.2

CHANGELOG.json

@@ -5,3 +5,18 @@ {
     {
-      "date": "Tue, 06 Dec 2022 00:47:50 GMT",
+      "date": "Thu, 08 Dec 2022 00:49:16 GMT",
+      "tag": "@lage-run/scheduler_v0.7.2",
+      "version": "0.7.2",
+      "comments": {
+        "patch": [
+          {
+            "author": "[e-mail]",
+            "package": "@lage-run/scheduler",
+            "commit": "ad281dfe8b222d949130821828a680d1c3625154",
+            "comment": "sets the default to progress"
+          }
+        ]
+      }
+    },
+    {
+      "date": "Tue, 06 Dec 2022 00:48:02 GMT",
       "tag": "@lage-run/scheduler_v0.7.1",
@@ -8,0 +23,0 @@ "version": "0.7.1",

CHANGELOG.md

 # Change Log - @lage-run/scheduler
 
-This log was last generated on Tue, 06 Dec 2022 00:47:50 GMT and should not be manually modified.
+This log was last generated on Thu, 08 Dec 2022 00:49:16 GMT and should not be manually modified.
 
 <!-- Start content -->
 
+## 0.7.2
+
+Thu, 08 Dec 2022 00:49:16 GMT
+
+### Patches
+
+- sets the default to progress ([e-mail])
+
 ## 0.7.1
 
-Tue, 06 Dec 2022 00:47:50 GMT
+Tue, 06 Dec 2022 00:48:02 GMT
 
@@ -11,0 +19,0 @@ ### Patches

lib/SimpleScheduler.d.ts

@@ -43,2 +43,3 @@ /// <reference types="node" />
     pool: Pool;
+    workerIds: number[];
     runPromise: Promise<any>;
@@ -45,0 +46,0 @@ constructor(options: SimpleSchedulerOptions);

lib/SimpleScheduler.js

@@ -48,2 +48,7 @@ "use strict";
         const { continueOnError , logger , cacheProvider , shouldCache , shouldResetCache , hasher  } = this.options;
+        logger.verbose("", {
+            schedulerRun: {
+                startTime
+            }
+        });
         const { pool , abortController  } = this;
@@ -179,2 +184,3 @@ const { targets  } = targetGraph;
         this.options.logger.verbose("", {
+            poolStats: this.pool.stats(),
             progress: {
@@ -219,2 +225,3 @@ waiting: targetRunByStatus.pending.length + targetRunByStatus.queued.length,
         });
+        this.workerIds = Array(options.concurrency).fill(0).map((_, idx)=>idx + 1);
     }
@@ -224,2 +231,4 @@ }
     let runError;
+    const threadId = this.workerIds.shift();
+    target.threadId = threadId;
     if (target.result && target.successful && !this.rerunTargets.has(target.target.id)) {
@@ -246,2 +255,4 @@ await target.result;
     }
+    this.workerIds.unshift(threadId);
+    this.workerIds.sort();
     this.logProgress();
@@ -248,0 +259,0 @@ // finally do another round of scheduling to run next round of targets

lib/WrappedTarget.js

@@ -195,4 +195,3 @@ "use strict";
             target
-        }, target.weight ?? 1, (worker, stdout, stderr)=>{
-            this.threadId = worker.threadId;
+        }, target.weight ?? 1, (_worker, stdout, stderr)=>{
             this.onStart();
@@ -199,0 +198,0 @@ stdout.pipe(bufferStdout.transform);

package.json

 {
   "name": "@lage-run/scheduler",
-  "version": "0.7.1",
+  "version": "0.7.2",
   "description": "Scheduler for Lage",
@@ -5,0 +5,0 @@ "repository": {

No alert changes

Improved metrics

Total package byte prevSize

99093

increased by0.9%

Lines of code

2589

increased by1.01%

No dependency changes