parameterize s3
parent
a6c78aed1b
commit
ea054001ff
|
|
@ -3267,7 +3267,6 @@ class Kubernetes {
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
runTaskInWorkflow(buildGuid, image, commands, mountdir, workingdir, environment, secrets) {
|
runTaskInWorkflow(buildGuid, image, commands, mountdir, workingdir, environment, secrets) {
|
||||||
var _a, _b;
|
|
||||||
return __awaiter(this, void 0, void 0, function* () {
|
return __awaiter(this, void 0, void 0, function* () {
|
||||||
try {
|
try {
|
||||||
cloud_runner_logger_1.default.log('Cloud Runner K8s workflow!');
|
cloud_runner_logger_1.default.log('Cloud Runner K8s workflow!');
|
||||||
|
|
@ -3302,12 +3301,12 @@ class Kubernetes {
|
||||||
try {
|
try {
|
||||||
errorParsed = JSON.parse(error);
|
errorParsed = JSON.parse(error);
|
||||||
}
|
}
|
||||||
catch (_c) {
|
catch (_a) {
|
||||||
errorParsed = error;
|
errorParsed = error;
|
||||||
}
|
}
|
||||||
const reason = errorParsed.reason || ((_b = (_a = errorParsed.response) === null || _a === void 0 ? void 0 : _a.body) === null || _b === void 0 ? void 0 : _b.reason) || ``;
|
// const reason = errorParsed.reason || errorParsed.response?.body?.reason || ``;
|
||||||
const errorMessage = errorParsed.message || ``;
|
const errorMessage = errorParsed.message || ``;
|
||||||
const continueStreaming = reason === `NotFound` || errorMessage.includes(`dial timeout, backstop`);
|
const continueStreaming = errorMessage.includes(`dial timeout, backstop`) || errorMessage.includes(`HttpError: HTTP request failed`);
|
||||||
if (continueStreaming) {
|
if (continueStreaming) {
|
||||||
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));
|
yield new Promise((resolve) => resolve(5000));
|
||||||
|
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -162,10 +162,12 @@ class Kubernetes implements ProviderInterface {
|
||||||
} catch {
|
} catch {
|
||||||
errorParsed = error;
|
errorParsed = error;
|
||||||
}
|
}
|
||||||
const reason = errorParsed.reason || errorParsed.response?.body?.reason || ``;
|
|
||||||
|
// const reason = errorParsed.reason || errorParsed.response?.body?.reason || ``;
|
||||||
const errorMessage = errorParsed.message || ``;
|
const errorMessage = errorParsed.message || ``;
|
||||||
|
|
||||||
const continueStreaming = errorMessage.includes(`dial timeout, backstop`);
|
const continueStreaming =
|
||||||
|
errorMessage.includes(`dial timeout, backstop`) || errorMessage.includes(`HttpError: HTTP request failed`);
|
||||||
if (continueStreaming) {
|
if (continueStreaming) {
|
||||||
CloudRunnerLogger.log('Log Stream Container Not Found');
|
CloudRunnerLogger.log('Log Stream Container Not Found');
|
||||||
await new Promise((resolve) => resolve(5000));
|
await new Promise((resolve) => resolve(5000));
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue