stubbing inspection api
parent
1b3e995bc4
commit
a8130252fe
|
|
@ -2409,7 +2409,11 @@ class AWSBuildEnvironment {
|
|||
});
|
||||
}
|
||||
watchWorkflow() {
|
||||
throw new Error('Method not implemented.');
|
||||
return __awaiter(this, void 0, void 0, function* () {
|
||||
// eslint-disable-next-line no-unused-vars
|
||||
const { output, shouldCleanup } = yield aws_task_runner_1.default.streamLogsUntilTaskStops(process.env.cluster || ``, process.env.taskArn || ``, process.env.streamName || ``);
|
||||
return output;
|
||||
});
|
||||
}
|
||||
listOtherResources() {
|
||||
return __awaiter(this, void 0, void 0, function* () {
|
||||
|
|
|
|||
File diff suppressed because one or more lines are too long
|
|
@ -2,12 +2,12 @@ import * as SDK from 'aws-sdk';
|
|||
import CloudRunnerSecret from '../../services/cloud-runner-secret';
|
||||
import CloudRunnerEnvironmentVariable from '../../services/cloud-runner-environment-variable';
|
||||
import CloudRunnerAWSTaskDef from './cloud-runner-aws-task-def';
|
||||
import AWSTaskRunner from './aws-task-runner';
|
||||
import AwsTaskRunner from './aws-task-runner';
|
||||
import { ProviderInterface } from '../provider-interface';
|
||||
import BuildParameters from '../../../build-parameters';
|
||||
import CloudRunnerLogger from '../../services/cloud-runner-logger';
|
||||
import { AWSJobStack } from './aws-job-stack';
|
||||
import { AWSBaseStack } from './aws-base-stack';
|
||||
import { AWSJobStack as AwsJobStack } from './aws-job-stack';
|
||||
import { AWSBaseStack as AwsBaseStack } from './aws-base-stack';
|
||||
import { Input } from '../../..';
|
||||
import { AwsCliCommands } from './commands/aws-cli-commands';
|
||||
import { TertiaryResourcesService } from './services/tertiary-resources-service';
|
||||
|
|
@ -23,8 +23,15 @@ class AWSBuildEnvironment implements ProviderInterface {
|
|||
async inspectResources(): Promise<string> {
|
||||
return await TaskService.awsDescribeJob('');
|
||||
}
|
||||
watchWorkflow(): Promise<string> {
|
||||
throw new Error('Method not implemented.');
|
||||
async watchWorkflow(): Promise<string> {
|
||||
// eslint-disable-next-line no-unused-vars
|
||||
const { output, shouldCleanup } = await AwsTaskRunner.streamLogsUntilTaskStops(
|
||||
process.env.cluster || ``,
|
||||
process.env.taskArn || ``,
|
||||
process.env.streamName || ``,
|
||||
);
|
||||
|
||||
return output;
|
||||
}
|
||||
|
||||
async listOtherResources(): Promise<string> {
|
||||
|
|
@ -89,14 +96,14 @@ class AWSBuildEnvironment implements ProviderInterface {
|
|||
process.env.AWS_REGION = Input.region;
|
||||
const ECS = new SDK.ECS();
|
||||
const CF = new SDK.CloudFormation();
|
||||
AWSTaskRunner.ECS = ECS;
|
||||
AWSTaskRunner.Kinesis = new SDK.Kinesis();
|
||||
AwsTaskRunner.ECS = ECS;
|
||||
AwsTaskRunner.Kinesis = new SDK.Kinesis();
|
||||
CloudRunnerLogger.log(`AWS Region: ${CF.config.region}`);
|
||||
const entrypoint = ['/bin/sh'];
|
||||
const startTimeMs = Date.now();
|
||||
|
||||
await new AWSBaseStack(this.baseStackName).setupBaseStack(CF);
|
||||
const taskDef = await new AWSJobStack(this.baseStackName).setupCloudFormations(
|
||||
await new AwsBaseStack(this.baseStackName).setupBaseStack(CF);
|
||||
const taskDef = await new AwsJobStack(this.baseStackName).setupCloudFormations(
|
||||
CF,
|
||||
buildGuid,
|
||||
image,
|
||||
|
|
@ -111,7 +118,7 @@ class AWSBuildEnvironment implements ProviderInterface {
|
|||
try {
|
||||
const postSetupStacksTimeMs = Date.now();
|
||||
CloudRunnerLogger.log(`Setup job time: ${Math.floor((postSetupStacksTimeMs - startTimeMs) / 1000)}s`);
|
||||
const { output, shouldCleanup } = await AWSTaskRunner.runTask(taskDef, environment, commands);
|
||||
const { output, shouldCleanup } = await AwsTaskRunner.runTask(taskDef, environment, commands);
|
||||
postRunTaskTimeMs = Date.now();
|
||||
CloudRunnerLogger.log(`Run job time: ${Math.floor((postRunTaskTimeMs - postSetupStacksTimeMs) / 1000)}s`);
|
||||
if (shouldCleanup) {
|
||||
|
|
|
|||
Loading…
Reference in New Issue