disable aws pipe for now

pull/531/head
Frostebite 2023-07-05 22:25:51 +01:00
parent 1040f80e74
commit ec2b38dc19
3 changed files with 34 additions and 9 deletions

19
dist/index.js generated vendored
View File

@ -3932,10 +3932,21 @@ class KubernetesTaskRunner {
break;
}
}
const configMapLogs = await kubeClient.readNamespacedConfigMap(`${jobName}-logs`, namespace);
if (configMapLogs.body.data) {
const logs = configMapLogs.body.data[`logs`] || ``;
cloud_runner_logger_1.default.log(logs);
try {
const configMapLogs = await kubeClient.readNamespacedConfigMap(`${jobName}-logs`, namespace);
if (configMapLogs.body.data) {
const logs = configMapLogs.body.data[`logs`] || ``;
cloud_runner_logger_1.default.log(logs);
}
}
catch (error) {
cloud_runner_logger_1.default.log(`Error reading config map ${error}`);
const configMaps = await kubeClient.listNamespacedConfigMap(namespace);
cloud_runner_logger_1.default.log(JSON.stringify(configMaps.body.items.map((x) => {
return {
name: x.metadata?.name || ``,
};
})));
}
return output;
}

2
dist/index.js.map generated vendored

File diff suppressed because one or more lines are too long

View File

@ -101,10 +101,24 @@ class KubernetesTaskRunner {
}
}
const configMapLogs = await kubeClient.readNamespacedConfigMap(`${jobName}-logs`, namespace);
if (configMapLogs.body.data) {
const logs = configMapLogs.body.data[`logs`] || ``;
CloudRunnerLogger.log(logs);
try {
const configMapLogs = await kubeClient.readNamespacedConfigMap(`${jobName}-logs`, namespace);
if (configMapLogs.body.data) {
const logs = configMapLogs.body.data[`logs`] || ``;
CloudRunnerLogger.log(logs);
}
} catch (error) {
CloudRunnerLogger.log(`Error reading config map ${error}`);
const configMaps = await kubeClient.listNamespacedConfigMap(namespace);
CloudRunnerLogger.log(
JSON.stringify(
configMaps.body.items.map((x) => {
return {
name: x.metadata?.name || ``,
};
}),
),
);
}
return output;