nx-cloud - npm Package Compare versions

Comparing version 14.0.3-beta.2 to 14.0.3-beta.3

lib/core/runners/cloud-enabled/cloud-enabled-life-cycle.js

@@ -7,2 +7,3 @@ "use strict";
 const fs_1 = require("fs");
+const environment_1 = require("../../../utilities/environment");
 const { appRootPath, unparse } = require('../../../utilities/nx-imports');
@@ -34,3 +35,3 @@ class CloudEnabledLifeCycle {
             hashDetails: this.cleanUpHashDetails(task.hashDetails),
-            params: unparse(overrides).join(' '),
+            params: unparse(overrides).join(' ')
         });
@@ -66,3 +67,4 @@ }
     }
-    endCommand() { }
+    endCommand() {
+    }
     updateStartedTask(task, code, cacheStatus) {
@@ -97,2 +99,4 @@ const startedTask = this.tasks.find((t) => t.taskId === task.id);
             const taskOutputSanitized = this.outputObfuscator.obfuscate(taskOutput);
+            if (environment_1.NX_CLOUD_UNLIMITED_OUTPUT)
+                return taskOutputSanitized;
             const maxCharacters = cacheStatus === 'cache-miss'
@@ -121,3 +125,3 @@ ? code === 0
             runtime: hashDetails.runtime,
-            implicitDeps: hashDetails.implicitDeps,
+            implicitDeps: hashDetails.implicitDeps
         };
@@ -124,0 +128,0 @@ }

lib/nx-cloud-tasks-runner.js

@@ -23,4 +23,3 @@ "use strict";
     if (environment_1.NX_INVOKED_BY_RUNNER) {
-        // if (anyCacheableTargets()) {
-        if (true) {
+        if (anyCacheableTargets(tasks, options)) {
             return (0, cloud_enabled_runner_1.cloudEnabledTasksRunner)(tasks, options, context, true);
@@ -51,4 +50,4 @@ }
                     '',
-                    'Execution will now continue using this machine only.',
-                ],
+                    'Execution will now continue using this machine only.'
+                ]
             });
@@ -70,5 +69,14 @@ // This disables using Cloud for all inner nx invocations, so it won't create an extra run.
 }
+function anyCacheableTargets(tasks, options) {
+    const cacheableTargets = options.cacheableOperations || [];
+    for (const task of tasks) {
+        if (cacheableTargets.indexOf(task.target.target) > -1) {
+            return true;
+        }
+    }
+    return false;
+}
 function verifyAllOperationsAreCacheableOnMainJob(tasks, options) {
     const cacheableTargets = options.cacheableOperations || [];
-    tasks.forEach((task) => {
+    for (const task of tasks) {
         if (cacheableTargets.indexOf(task.target.target) === -1) {
@@ -81,8 +89,8 @@ output.error({
                     `You can verify that '${task.target.target}' is part of the list of cacheable targets in the 'nx.json' file.`,
-                    `You can invoke this command without distribution by doing "NX_CLOUD_DISTRIBUTED_EXECUTION=false nx ...".`,
-                ],
+                    `You can invoke this command without distribution by doing "NX_CLOUD_DISTRIBUTED_EXECUTION=false nx ...".`
+                ]
             });
             process.exit(1);
         }
-    });
+    }
 }
@@ -98,4 +106,4 @@ function verifyAllOperationsAreCacheableOnAgent(tasks, options) {
                     `To be able to replay the output of the target, distributed task execution only supports cacheable targets.`,
-                    `You can still invoke "nx ${task.target.target} ${task.target.project}" from within a cacheable target when using "@nrwl/workspace:run-commands".`,
-                ],
+                    `You can still invoke "nx ${task.target.target} ${task.target.project}" from within a cacheable target when using "@nrwl/workspace:run-commands".`
+                ]
             });
@@ -102,0 +110,0 @@ process.exit(environment_1.DISTRIBUTED_TASK_EXECUTION_INTERNAL_ERROR_STATUS_CODE);

lib/utilities/environment.d.ts

@@ -6,2 +6,3 @@ import { CloudTaskRunnerOptions } from '../core/models/cloud-task-runner-options';
 export declare const UNLIMITED_FILE_SIZE: number;
+export declare const NX_CLOUD_UNLIMITED_OUTPUT: boolean;
 export declare const DEFAULT_FILE_SIZE_LIMIT: number;
@@ -8,0 +9,0 @@ export declare const DISTRIBUTED_TASK_EXECUTION_INTERNAL_ERROR_STATUS_CODE = 166;

lib/utilities/environment.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.parseCommand = exports.getMachineInfo = exports.getBranch = exports.getRunGroup = exports.extractGitSha = exports.NX_CLOUD_NO_TIMEOUTS = exports.VERBOSE_LOGGING = exports.ENCRYPTION_KEY = exports.ACCESS_TOKEN = exports.NX_CLOUD_FORCE_METRICS = exports.NX_CLOUD_DISTRIBUTED_EXECUTION_STOP_AGENTS_ON_FAILURE = exports.NX_CLOUD_DISTRIBUTED_EXECUTION_AGENT_COUNT = exports.NUMBER_OF_AXIOS_RETRIES = exports.NX_CLOUD_DISTRIBUTED_EXECUTION = exports.AGENT_RUNNING_IN_DISTRIBUTED_EXECUTION = exports.NX_CLOUD_DISTRIBUTED_EXECUTION_ID = exports.NX_INVOKED_BY_RUNNER = exports.DISTRIBUTED_TASK_EXECUTION_INTERNAL_ERROR_STATUS_CODE = exports.DEFAULT_FILE_SIZE_LIMIT = exports.UNLIMITED_FILE_SIZE = exports.NO_MESSAGES_TIMEOUT = exports.UNLIMITED_TIMEOUT = void 0;
+exports.parseCommand = exports.getMachineInfo = exports.getBranch = exports.getRunGroup = exports.extractGitSha = exports.NX_CLOUD_NO_TIMEOUTS = exports.VERBOSE_LOGGING = exports.ENCRYPTION_KEY = exports.ACCESS_TOKEN = exports.NX_CLOUD_FORCE_METRICS = exports.NX_CLOUD_DISTRIBUTED_EXECUTION_STOP_AGENTS_ON_FAILURE = exports.NX_CLOUD_DISTRIBUTED_EXECUTION_AGENT_COUNT = exports.NUMBER_OF_AXIOS_RETRIES = exports.NX_CLOUD_DISTRIBUTED_EXECUTION = exports.AGENT_RUNNING_IN_DISTRIBUTED_EXECUTION = exports.NX_CLOUD_DISTRIBUTED_EXECUTION_ID = exports.NX_INVOKED_BY_RUNNER = exports.DISTRIBUTED_TASK_EXECUTION_INTERNAL_ERROR_STATUS_CODE = exports.DEFAULT_FILE_SIZE_LIMIT = exports.NX_CLOUD_UNLIMITED_OUTPUT = exports.UNLIMITED_FILE_SIZE = exports.NO_MESSAGES_TIMEOUT = exports.UNLIMITED_TIMEOUT = void 0;
 const node_machine_id_1 = require("node-machine-id");
@@ -13,2 +13,3 @@ const child_process_1 = require("child_process");
 exports.UNLIMITED_FILE_SIZE = 1000 * 1000 * 10000;
+exports.NX_CLOUD_UNLIMITED_OUTPUT = process.env.NX_CLOUD_UNLIMITED_OUTPUT === 'true';
 exports.DEFAULT_FILE_SIZE_LIMIT = 1000 * 1000 * 300;
@@ -140,3 +141,4 @@ exports.DISTRIBUTED_TASK_EXECUTION_INTERNAL_ERROR_STATUS_CODE = 166;
         }
-        catch (_a) { }
+        catch (_a) {
+        }
     }
@@ -147,3 +149,3 @@ return {
         version: os.version ? os.version() : '',
-        cpuCores: os.cpus().length,
+        cpuCores: os.cpus().length
     };
@@ -150,0 +152,0 @@ }

package.json

 {
   "name": "nx-cloud",
-  "version": "14.0.3-beta.2",
+  "version": "14.0.3-beta.3",
   "description": "Nx Cloud plugin for Nx",
@@ -5,0 +5,0 @@ "keywords": [

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

250062

increased by0.4%

Lines of code

3291

increased by0.46%

Number of medium supply chain risk alerts

3

decreased by-25%

Worsened metrics

Number of low supply chain risk alerts

83

increased by1.22%

No dependency changes