cleanup & retained mode test for k8s and aws

pull/437/head
Frostebite 2022-11-03 21:08:23 +00:00
parent b710053f10
commit bb8c1d536e
3 changed files with 5 additions and 1 deletions

2
dist/index.js vendored
View File

@ -3090,6 +3090,8 @@ class Kubernetes {
const reason = ((_d = (_c = error.response) === null || _c === void 0 ? void 0 : _c.body) === null || _d === void 0 ? void 0 : _d.reason) || ``; const reason = ((_d = (_c = error.response) === null || _c === void 0 ? void 0 : _c.body) === null || _d === void 0 ? void 0 : _d.reason) || ``;
if (reason === `NotFound`) { if (reason === `NotFound`) {
cloud_runner_logger_1.default.log('Log Stream Container Not Found'); cloud_runner_logger_1.default.log('Log Stream Container Not Found');
yield new Promise((resolve) => resolve(5000));
continue;
} }
else { else {
cloud_runner_logger_1.default.log(`error running k8s workflow ${error}`); cloud_runner_logger_1.default.log(`error running k8s workflow ${error}`);

2
dist/index.js.map vendored

File diff suppressed because one or more lines are too long

View File

@ -165,6 +165,8 @@ class Kubernetes implements ProviderInterface {
const reason = error.response?.body?.reason || ``; const reason = error.response?.body?.reason || ``;
if (reason === `NotFound`) { if (reason === `NotFound`) {
CloudRunnerLogger.log('Log Stream Container Not Found'); CloudRunnerLogger.log('Log Stream Container Not Found');
await new Promise((resolve) => resolve(5000));
continue;
} else { } else {
CloudRunnerLogger.log(`error running k8s workflow ${error}`); CloudRunnerLogger.log(`error running k8s workflow ${error}`);
throw error; throw error;