Improve k8s logging accuracy
parent
e833b5e231
commit
04b01c4e50
|
|
@ -3294,7 +3294,7 @@ class Kubernetes {
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
runTaskInWorkflow(buildGuid, image, commands, mountdir, workingdir, environment, secrets) {
|
runTaskInWorkflow(buildGuid, image, commands, mountdir, workingdir, environment, secrets) {
|
||||||
var _a, _b;
|
var _a, _b, _c;
|
||||||
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!');
|
||||||
|
|
@ -3311,10 +3311,10 @@ class Kubernetes {
|
||||||
let existsAlready = false;
|
let existsAlready = false;
|
||||||
try {
|
try {
|
||||||
const status = yield this.kubeClient.readNamespacedPodStatus(this.podName, this.namespace);
|
const status = yield this.kubeClient.readNamespacedPodStatus(this.podName, this.namespace);
|
||||||
cloud_runner_logger_1.default.log(JSON.stringify(status, undefined, 4));
|
cloud_runner_logger_1.default.log(JSON.stringify((_a = status.body.status) === null || _a === void 0 ? void 0 : _a.containerStatuses, undefined, 4));
|
||||||
existsAlready = true;
|
existsAlready = true;
|
||||||
}
|
}
|
||||||
catch (_c) {
|
catch (_d) {
|
||||||
// empty
|
// empty
|
||||||
}
|
}
|
||||||
if (!existsAlready) {
|
if (!existsAlready) {
|
||||||
|
|
@ -3342,10 +3342,10 @@ class Kubernetes {
|
||||||
try {
|
try {
|
||||||
errorParsed = JSON.parse(error);
|
errorParsed = JSON.parse(error);
|
||||||
}
|
}
|
||||||
catch (_d) {
|
catch (_e) {
|
||||||
errorParsed = error;
|
errorParsed = error;
|
||||||
}
|
}
|
||||||
const errorMessage = errorParsed.name || errorParsed.reason || ((_b = (_a = errorParsed.response) === null || _a === void 0 ? void 0 : _a.body) === null || _b === void 0 ? void 0 : _b.reason) || errorParsed.message;
|
const errorMessage = errorParsed.name || errorParsed.reason || ((_c = (_b = errorParsed.response) === null || _b === void 0 ? void 0 : _b.body) === null || _c === void 0 ? void 0 : _c.reason) || errorParsed.message;
|
||||||
const continueStreaming = errorMessage.includes(`dial timeout, backstop`) ||
|
const continueStreaming = errorMessage.includes(`dial timeout, backstop`) ||
|
||||||
errorMessage.includes(`HttpError`) ||
|
errorMessage.includes(`HttpError`) ||
|
||||||
errorMessage.includes(`HttpError: HTTP request failed`) ||
|
errorMessage.includes(`HttpError: HTTP request failed`) ||
|
||||||
|
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -136,7 +136,7 @@ class Kubernetes implements ProviderInterface {
|
||||||
let existsAlready = false;
|
let existsAlready = false;
|
||||||
try {
|
try {
|
||||||
const status = await this.kubeClient.readNamespacedPodStatus(this.podName, this.namespace);
|
const status = await this.kubeClient.readNamespacedPodStatus(this.podName, this.namespace);
|
||||||
CloudRunnerLogger.log(JSON.stringify(status, undefined, 4));
|
CloudRunnerLogger.log(JSON.stringify(status.body.status?.containerStatuses, undefined, 4));
|
||||||
existsAlready = true;
|
existsAlready = true;
|
||||||
} catch {
|
} catch {
|
||||||
// empty
|
// empty
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue