actions
/
unity-builder
mirror of https://github.com/game-ci/unity-builder.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

async stream destroy and await

pull/310/head
Frostebite 2022-01-31 22:41:29 +00:00
parent 6d3fc39705
commit d29e077c0e
3 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
dist/index.js vendored
View File

@ -2533,7 +2533,8 @@ class KubernetesTaskRunner {
previous: false,
};
try {
const resultError = yield new Promise((resolve) => __awaiter(this, void 0, void 0, function* () { return new client_node_1.Log(kubeConfig).log(namespace, podName, containerName, stream, resolve, logOptions); }));
const resultError = yield new Promise((resolve) => __awaiter(this, void 0, void 0, function* () { return yield new client_node_1.Log(kubeConfig).log(namespace, podName, containerName, stream, resolve, logOptions); }));
stream.removeAllListeners();
stream.destroy();
if (resultError) {
throw resultError;

2
dist/index.js.map vendored
View File

File diff suppressed because one or more lines are too long

6
src/model/cloud-runner/k8s/kubernetes-task-runner.ts
View File

@ -36,9 +36,11 @@ class KubernetesTaskRunner {
previous: false,
};
try {
const resultError = await new Promise(async (resolve) =>
new Log(kubeConfig).log(namespace, podName, containerName, stream, resolve, logOptions),
const resultError = await new Promise(
async (resolve) =>
await new Log(kubeConfig).log(namespace, podName, containerName, stream, resolve, logOptions),
);
stream.removeAllListeners();
stream.destroy();
if (resultError) {
throw resultError;