@lage-run/scheduler
Advanced tools
Comparing version 1.3.8 to 1.3.9
# Change Log - @lage-run/scheduler | ||
<!-- This log was last generated on Fri, 08 Nov 2024 19:27:31 GMT and should not be manually modified. --> | ||
<!-- This log was last generated on Fri, 08 Nov 2024 19:44:39 GMT and should not be manually modified. --> | ||
<!-- Start content --> | ||
## 1.3.9 | ||
Fri, 08 Nov 2024 19:44:39 GMT | ||
### Patches | ||
- Bump @lage-run/cache to v1.3.8 | ||
- Bump @lage-run/config to v0.4.8 | ||
- Bump @lage-run/hasher to v1.6.4 | ||
- Bump @lage-run/runners to v1.1.0 | ||
- Bump @lage-run/target-graph to v0.10.0 | ||
- Bump @lage-run/scheduler-types to v0.3.20 | ||
## 1.3.8 | ||
Fri, 08 Nov 2024 19:27:31 GMT | ||
Fri, 08 Nov 2024 19:27:44 GMT | ||
@@ -11,0 +24,0 @@ ### Patches |
@@ -14,3 +14,3 @@ "use strict"; | ||
async function createCache(options) { | ||
const { cacheOptions , logger , root , skipLocalCache } = options; | ||
const { cacheOptions, logger, root, skipLocalCache } = options; | ||
const hasRemoteCacheConfig = !!cacheOptions?.cacheStorageConfig || !!process.env.BACKFILL_CACHE_PROVIDER || !!process.env.BACKFILL_CACHE_PROVIDER_OPTIONS; | ||
@@ -17,0 +17,0 @@ // Create Cache Provider |
@@ -22,3 +22,3 @@ "use strict"; | ||
for (const targetRun of targetRuns){ | ||
const { status } = targetRun; | ||
const { status } = targetRun; | ||
if (!targetRun.target.hidden) { | ||
@@ -25,0 +25,0 @@ summary[status].push(targetRun.target.id); |
@@ -63,3 +63,3 @@ "use strict"; | ||
const startTime = process.hrtime(); | ||
const { continueOnError , logger , shouldCache } = this.options; | ||
const { continueOnError, logger, shouldCache } = this.options; | ||
logger.verbose("", { | ||
@@ -70,4 +70,4 @@ schedulerRun: { | ||
}); | ||
const { pool , abortController } = this; | ||
const { targets } = targetGraph; | ||
const { pool, abortController } = this; | ||
const { targets } = targetGraph; | ||
for (const target of targets.values()){ | ||
@@ -242,3 +242,3 @@ let targetRun; | ||
maxWorkersByGroup: options.maxWorkersPerTask, | ||
groupBy: ({ target })=>target.task, | ||
groupBy: ({ target })=>target.task, | ||
maxWorkers: options.concurrency, | ||
@@ -245,0 +245,0 @@ script: require.resolve("./workers/targetWorker"), |
@@ -16,3 +16,3 @@ "use strict"; | ||
async function setup(options) { | ||
const { runners , root , cacheOptions } = options; | ||
const { runners, root, cacheOptions } = options; | ||
const logger = (0, _logger.default)(); | ||
@@ -28,3 +28,3 @@ logger.addReporter({ | ||
}); | ||
const { cacheProvider } = await (0, _createCacheProvider.createCache)({ | ||
const { cacheProvider } = await (0, _createCacheProvider.createCache)({ | ||
root, | ||
@@ -44,3 +44,3 @@ logger, | ||
(async ()=>{ | ||
const { cacheProvider , runnerPicker , options } = await setup(_worker_threads.workerData); | ||
const { cacheProvider, runnerPicker, options } = await setup(_worker_threads.workerData); | ||
// eslint-disable-next-line @typescript-eslint/no-unused-vars | ||
@@ -55,3 +55,3 @@ let hashPromiseResolve = (_hash)=>{}; | ||
async function getCache(target) { | ||
const { shouldCache , shouldResetCache } = options; | ||
const { shouldCache, shouldResetCache } = options; | ||
let hash = undefined; | ||
@@ -87,3 +87,3 @@ let cacheHit = false; | ||
async function run(data, abortSignal) { | ||
const { hash , cacheHit } = await getCache(data.target); | ||
const { hash, cacheHit } = await getCache(data.target); | ||
const cacheEnabled = data.target.cache && options.shouldCache && hash; | ||
@@ -90,0 +90,0 @@ let value = undefined; |
@@ -160,3 +160,3 @@ "use strict"; | ||
async run() { | ||
const { target , logger , shouldCache , abortController , root } = this.options; | ||
const { target, logger, shouldCache, abortController, root } = this.options; | ||
const abortSignal = abortController.signal; | ||
@@ -185,3 +185,3 @@ if (abortSignal.aborted) { | ||
if (_class_private_field_get(this, _result).skipped) { | ||
const { hash } = _class_private_field_get(this, _result); | ||
const { hash } = _class_private_field_get(this, _result); | ||
const cachedOutputFile = (0, _getLageOutputCacheLocation.getLageOutputCacheLocation)(root, hash ?? ""); | ||
@@ -216,3 +216,3 @@ const shouldShowCachedOutput = _fs.default.existsSync(cachedOutputFile); | ||
async runInPool() { | ||
const { target , logger , abortController , pool } = this.options; | ||
const { target, logger, abortController, pool } = this.options; | ||
const abortSignal = abortController.signal; | ||
@@ -219,0 +219,0 @@ let releaseStdout; |
{ | ||
"name": "@lage-run/scheduler", | ||
"version": "1.3.8", | ||
"version": "1.3.9", | ||
"description": "Scheduler for Lage", | ||
@@ -20,8 +20,8 @@ "repository": { | ||
"dependencies": { | ||
"@lage-run/cache": "^1.3.7", | ||
"@lage-run/config": "^0.4.7", | ||
"@lage-run/hasher": "^1.6.3", | ||
"@lage-run/cache": "^1.3.8", | ||
"@lage-run/config": "^0.4.8", | ||
"@lage-run/hasher": "^1.6.4", | ||
"@lage-run/logger": "^1.3.1", | ||
"@lage-run/runners": "^1.0.7", | ||
"@lage-run/target-graph": "^0.9.3", | ||
"@lage-run/runners": "^1.1.0", | ||
"@lage-run/target-graph": "^0.10.0", | ||
"@lage-run/worker-threads-pool": "^0.8.4" | ||
@@ -31,3 +31,3 @@ }, | ||
"@lage-run/monorepo-scripts": "*", | ||
"@lage-run/scheduler-types": "^0.3.19" | ||
"@lage-run/scheduler-types": "^0.3.20" | ||
}, | ||
@@ -34,0 +34,0 @@ "publishConfig": { |
Sorry, the diff of this file is too big to display
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
201341
36
4048
- Removed@lage-run/target-graph@0.9.3(transitive)
- Removedworkspace-tools@0.37.0(transitive)
Updated@lage-run/cache@^1.3.8
Updated@lage-run/config@^0.4.8
Updated@lage-run/hasher@^1.6.4
Updated@lage-run/runners@^1.1.0