stream logs through standard input and new remote client cli command
parent
c366060834
commit
1867dcefbb
|
@ -3923,6 +3923,11 @@ class KubernetesTaskRunner {
|
||||||
break;
|
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);
|
||||||
|
}
|
||||||
return output;
|
return output;
|
||||||
}
|
}
|
||||||
static async watchUntilPodRunning(kubeClient, podName, namespace) {
|
static async watchUntilPodRunning(kubeClient, podName, namespace) {
|
||||||
|
|
File diff suppressed because one or more lines are too long
|
@ -101,6 +101,12 @@ class KubernetesTaskRunner {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const configMapLogs = await kubeClient.readNamespacedConfigMap(`${jobName}-logs`, namespace);
|
||||||
|
if (configMapLogs.body.data) {
|
||||||
|
const logs = configMapLogs.body.data[`logs`] || ``;
|
||||||
|
CloudRunnerLogger.log(logs);
|
||||||
|
}
|
||||||
|
|
||||||
return output;
|
return output;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue