Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

@lage-run/scheduler

Package Overview
Dependencies
Maintainers
0
Versions
126
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@lage-run/scheduler - npm Package Compare versions

Comparing version 1.3.8 to 1.3.9

lib/bufferTransform.js.map

17

CHANGELOG.md
# 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

2

lib/cache/createCacheProvider.js

@@ -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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc