nx-cloud - npm Package Compare versions

Comparing version 16.1.0-beta.1 to 16.1.0-beta.2

lib/core/api/run-group.api.d.ts

@@ -5,4 +5,4 @@ import { CloudTaskRunnerOptions } from '../models/cloud-task-runner-options';
     constructor(options: CloudTaskRunnerOptions);
-    createRunGroup(branch: string | null, runGroup: string, ciExecutionId: string | null, ciExecutionEnv: string, stopAgentsOnFailure?: boolean, agentCount?: number, stopAgentsAfter?: string, commitSha?: string): Promise<void>;
+    createRunGroup(branch: string | null, runGroup: string, ciExecutionId: string | null, ciExecutionEnv: string, stopAgentsOnFailure?: boolean, agentCount?: number, stopAgentsAfter?: string, commitSha?: string, commitRef?: string): Promise<void>;
     completeRunGroup(branch: string | null, runGroup: string, ciExecutionId: string | null, ciExecutionEnv: string): Promise<void>;
 }

lib/core/api/run-group.api.js

@@ -20,3 +20,3 @@ "use strict";
     }
-    createRunGroup(branch, runGroup, ciExecutionId, ciExecutionEnv, stopAgentsOnFailure, agentCount, stopAgentsAfter, commitSha) {
+    createRunGroup(branch, runGroup, ciExecutionId, ciExecutionEnv, stopAgentsOnFailure, agentCount, stopAgentsAfter, commitSha, commitRef) {
         var _a;
@@ -23,0 +23,0 @@ return __awaiter(this, void 0, void 0, function* () {

lib/core/commands/start-ci-run.js

@@ -36,2 +36,3 @@ "use strict";
         const commitSha = (0, environment_1.extractGitSha)();
+        const commitRef = (0, environment_1.extractGitRef)();
         if (!(0, print_run_group_error_1.canDetectRunGroup)(runGroup, ciExecutionId)) {
@@ -55,3 +56,3 @@ (0, print_run_group_error_1.printRunGroupError)();
         const api = new run_group_api_1.RunGroupApi(options);
-        yield api.createRunGroup(branch, runGroup, ciExecutionId, ciExecutionEnv, args.stopAgentsOnFailure, args.agentCount, args.stopAgentsAfter, commitSha);
+        yield api.createRunGroup(branch, runGroup, ciExecutionId, ciExecutionEnv, args.stopAgentsOnFailure, args.agentCount, args.stopAgentsAfter, commitSha, commitRef);
         if (args.useDteByDefault) {
@@ -58,0 +59,0 @@ (0, distributed_task_execution_detection_1.storeDteMarker)();

lib/core/file-storage/file-storage.js

@@ -209,2 +209,7 @@ "use strict";
             const tgz = this.createFileName(hash, cacheDirectory);
+            // we don't track source when sharing artifacts via cloud
+            try {
+                (0, fs_1.unlinkSync)(path.join(cacheDirectory, hash, 'source'));
+            }
+            catch (e) { }
             yield tar.c({
@@ -211,0 +216,0 @@ gzip: true,

lib/core/runners/distributed-execution/distributed-execution.runner.js

@@ -48,2 +48,3 @@ "use strict";
     const commitSha = (0, environment_1.extractGitSha)();
+    const commitRef = (0, environment_1.extractGitRef)();
     if (!(0, print_run_group_error_1.canDetectRunGroup)(runGroup, ciExecutionId)) {
@@ -60,3 +61,3 @@ (0, print_run_group_error_1.printRunGroupError)();
         const taskGraph = getTaskGraph(context, tasks, options);
-        const r = yield runDistributedExecution(api, options, dteArtifactStorage, branch, runGroup, ciExecutionId, ciExecutionEnv, taskGraph, commitSha);
+        const r = yield runDistributedExecution(api, options, dteArtifactStorage, branch, runGroup, ciExecutionId, ciExecutionEnv, taskGraph, commitSha, commitRef);
         if (r.commandStatus === 0) {
@@ -115,3 +116,3 @@ output.success({
 }
-function runDistributedExecution(api, options, dteArtifactStorage, branch, runGroup, ciExecutionId, ciExecutionEnv, taskGraph, commitSha) {
+function runDistributedExecution(api, options, dteArtifactStorage, branch, runGroup, ciExecutionId, ciExecutionEnv, taskGraph, commitSha, commitRef) {
     return __awaiter(this, void 0, void 0, function* () {
@@ -118,0 +119,0 @@ const id = yield api.start((0, distributed_execution_api_1.createStartRequest)(branch, runGroup, ciExecutionId, ciExecutionEnv, (0, split_task_graph_into_stages_1.splitTasksIntoStages)(taskGraph), options, commitSha));

lib/utilities/environment.d.ts

@@ -22,2 +22,3 @@ import { CloudTaskRunnerOptions } from '../core/models/cloud-task-runner-options';
 export declare function extractGitSha(): string | undefined;
+export declare function extractGitRef(): string | undefined;
 export declare function getCIExecutionId(): string | null;
@@ -24,0 +25,0 @@ export declare function getCIExecutionEnv(): any;

lib/utilities/environment.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.parseCommand = exports.getMachineInfo = exports.getBranch = exports.getRunGroup = exports.getCIExecutionEnv = exports.getCIExecutionId = exports.extractGitSha = exports.nxInvokedByRunner = exports.agentRunningInDistributedExecution = exports.NX_CLOUD_NO_TIMEOUTS = exports.VERBOSE_LOGGING = exports.ENCRYPTION_KEY = exports.ACCESS_TOKEN = exports.NX_NO_CLOUD = exports.NUMBER_OF_AXIOS_RETRIES = exports.NX_CLOUD_FORCE_METRICS = exports.NX_CLOUD_DISTRIBUTED_EXECUTION_STOP_AGENTS_ON_FAILURE = exports.NX_CLOUD_DISTRIBUTED_EXECUTION_AGENT_COUNT = exports.DISTRIBUTED_TASK_EXECUTION_INTERNAL_ERROR_STATUS_CODE = exports.DEFAULT_FILE_SIZE_LIMIT = exports.NX_CLOUD_UNLIMITED_OUTPUT = exports.UNLIMITED_FILE_SIZE = exports.NO_COMPLETED_TASKS_TIMEOUT = exports.NO_MESSAGES_TIMEOUT = exports.UNLIMITED_TIMEOUT = void 0;
+exports.parseCommand = exports.getMachineInfo = exports.getBranch = exports.getRunGroup = exports.getCIExecutionEnv = exports.getCIExecutionId = exports.extractGitRef = exports.extractGitSha = exports.nxInvokedByRunner = exports.agentRunningInDistributedExecution = exports.NX_CLOUD_NO_TIMEOUTS = exports.VERBOSE_LOGGING = exports.ENCRYPTION_KEY = exports.ACCESS_TOKEN = exports.NX_NO_CLOUD = exports.NUMBER_OF_AXIOS_RETRIES = exports.NX_CLOUD_FORCE_METRICS = exports.NX_CLOUD_DISTRIBUTED_EXECUTION_STOP_AGENTS_ON_FAILURE = exports.NX_CLOUD_DISTRIBUTED_EXECUTION_AGENT_COUNT = exports.DISTRIBUTED_TASK_EXECUTION_INTERNAL_ERROR_STATUS_CODE = exports.DEFAULT_FILE_SIZE_LIMIT = exports.NX_CLOUD_UNLIMITED_OUTPUT = exports.UNLIMITED_FILE_SIZE = exports.NO_COMPLETED_TASKS_TIMEOUT = exports.NO_MESSAGES_TIMEOUT = exports.UNLIMITED_TIMEOUT = void 0;
 const child_process_1 = require("child_process");
@@ -55,2 +55,15 @@ const dotenv = require("dotenv");
 exports.extractGitSha = extractGitSha;
+function extractGitRef() {
+    try {
+        return (0, child_process_1.execSync)(`git rev-parse --symbolic-full-name HEAD`, {
+            stdio: 'pipe',
+        })
+            .toString()
+            .trim();
+    }
+    catch (e) {
+        return undefined;
+    }
+}
+exports.extractGitRef = extractGitRef;
 function parseEnv() {
@@ -57,0 +70,0 @@ try {

package.json

 {
   "name": "nx-cloud",
-  "version": "16.1.0-beta.1",
+  "version": "16.1.0-beta.2",
   "description": "Distributed caching and task execution for Lerna and Nx",
@@ -32,4 +32,4 @@ "keywords": [
     "open": "~8.4.0",
-    "@nrwl/nx-cloud": "16.1.0-beta.1"
+    "@nrwl/nx-cloud": "16.1.0-beta.2"
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

360640

0.35%

Lines of code

4810

0.46%

Dependency changes

• + Added

  @nrwl/nx-cloud@16.1.0-beta.2
  (transitive)

• - Removed

  @nrwl/nx-cloud@16.1.0-beta.1
  (transitive)

• Updated

  @nrwl/nx-cloud@16.1.0-beta.2