lock test
parent
9ed3251455
commit
cefd469364
|
|
@ -619,9 +619,13 @@ const cloud_runner_system_1 = __nccwpck_require__(99393);
|
||||||
const fs = __importStar(__nccwpck_require__(57147));
|
const fs = __importStar(__nccwpck_require__(57147));
|
||||||
const cloud_runner_1 = __importDefault(__nccwpck_require__(79144));
|
const cloud_runner_1 = __importDefault(__nccwpck_require__(79144));
|
||||||
const cloud_runner_logger_1 = __importDefault(__nccwpck_require__(22855));
|
const cloud_runner_logger_1 = __importDefault(__nccwpck_require__(22855));
|
||||||
|
const cloud_runner_options_1 = __importDefault(__nccwpck_require__(96552));
|
||||||
class SharedWorkspaceLocking {
|
class SharedWorkspaceLocking {
|
||||||
static GetLockedWorkspace() {
|
static GetLockedWorkspace() {
|
||||||
return __awaiter(this, void 0, void 0, function* () {
|
return __awaiter(this, void 0, void 0, function* () {
|
||||||
|
if (!cloud_runner_options_1.default.retainWorkspaces) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
const workspaces = SharedWorkspaceLocking.GetFreeWorkspaces();
|
const workspaces = SharedWorkspaceLocking.GetFreeWorkspaces();
|
||||||
for (const element of workspaces) {
|
for (const element of workspaces) {
|
||||||
if (yield SharedWorkspaceLocking.LockWorkspace(element)) {
|
if (yield SharedWorkspaceLocking.LockWorkspace(element)) {
|
||||||
|
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -2,8 +2,13 @@ import { CloudRunnerSystem } from '../cloud-runner/services/cloud-runner-system'
|
||||||
import * as fs from 'fs';
|
import * as fs from 'fs';
|
||||||
import CloudRunner from '../cloud-runner/cloud-runner';
|
import CloudRunner from '../cloud-runner/cloud-runner';
|
||||||
import CloudRunnerLogger from '../cloud-runner/services/cloud-runner-logger';
|
import CloudRunnerLogger from '../cloud-runner/services/cloud-runner-logger';
|
||||||
|
import CloudRunnerOptions from '../cloud-runner/cloud-runner-options';
|
||||||
export class SharedWorkspaceLocking {
|
export class SharedWorkspaceLocking {
|
||||||
public static async GetLockedWorkspace() {
|
public static async GetLockedWorkspace() {
|
||||||
|
if (!CloudRunnerOptions.retainWorkspaces) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
const workspaces = SharedWorkspaceLocking.GetFreeWorkspaces();
|
const workspaces = SharedWorkspaceLocking.GetFreeWorkspaces();
|
||||||
for (const element of workspaces) {
|
for (const element of workspaces) {
|
||||||
if (await SharedWorkspaceLocking.LockWorkspace(element)) {
|
if (await SharedWorkspaceLocking.LockWorkspace(element)) {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue