cleanup & retained mode test for k8s and aws

pull/437/head
Frostebite 2022-11-03 18:03:24 +00:00
parent ac53014e71
commit bf1ef144b0
3 changed files with 5 additions and 1 deletions

2
dist/index.js vendored
View File

@ -1659,6 +1659,8 @@ class AWSTaskRunner {
} }
static streamLogsUntilTaskStops(clusterName, taskArn, kinesisStreamName) { static streamLogsUntilTaskStops(clusterName, taskArn, kinesisStreamName) {
return __awaiter(this, void 0, void 0, function* () { return __awaiter(this, void 0, void 0, function* () {
yield new Promise((resolve) => setTimeout(resolve, 3000));
cloud_runner_logger_1.default.log(`Streaming...`);
const stream = yield AWSTaskRunner.getLogStream(kinesisStreamName); const stream = yield AWSTaskRunner.getLogStream(kinesisStreamName);
let iterator = yield AWSTaskRunner.getLogIterator(stream); let iterator = yield AWSTaskRunner.getLogIterator(stream);
const logBaseUrl = `https://${__1.Input.region}.console.aws.amazon.com/cloudwatch/home?region=${__1.Input.region}#logsV2:log-groups/log-group/${cloud_runner_1.default.buildParameters.awsBaseStackName}-${cloud_runner_1.default.buildParameters.buildGuid}`; const logBaseUrl = `https://${__1.Input.region}.console.aws.amazon.com/cloudwatch/home?region=${__1.Input.region}#logsV2:log-groups/log-group/${cloud_runner_1.default.buildParameters.awsBaseStackName}-${cloud_runner_1.default.buildParameters.buildGuid}`;

2
dist/index.js.map vendored

File diff suppressed because one or more lines are too long

View File

@ -116,6 +116,8 @@ class AWSTaskRunner {
} }
static async streamLogsUntilTaskStops(clusterName: string, taskArn: string, kinesisStreamName: string) { static async streamLogsUntilTaskStops(clusterName: string, taskArn: string, kinesisStreamName: string) {
await new Promise((resolve) => setTimeout(resolve, 3000));
CloudRunnerLogger.log(`Streaming...`);
const stream = await AWSTaskRunner.getLogStream(kinesisStreamName); const stream = await AWSTaskRunner.getLogStream(kinesisStreamName);
let iterator = await AWSTaskRunner.getLogIterator(stream); let iterator = await AWSTaskRunner.getLogIterator(stream);