follow logs

dist/index.js

@@ -1048,13 +1048,20 @@ class Kubernetes {
             const pod = (yield Kubernetes.watchPodUntilReadyAndRead()) || {};
             core.info(`Watching build job ${(_a = pod.metadata) === null || _a === void 0 ? void 0 : _a.name}`);
             const logs = yield this.kubeClient.readNamespacedPodLog(((_b = pod.metadata) === null || _b === void 0 ? void 0 : _b.name) || '', this.namespace, (_d = (_c = pod.status) === null || _c === void 0 ? void 0 : _c.containerStatuses) === null || _d === void 0 ? void 0 : _d[0].containerID, true);
+            core.info('opening log stream');
             yield new Promise((resolve, reject) => {
+                try {
                     logs.response.on('data', (chunk) => {
                         core.info(chunk);
                     });
                     logs.response.on('close', resolve);
                     logs.response.on('error', reject);
                     logs.response.on('end', resolve);
+                }
+                catch (error) {
+                    core.error(error);
+                    throw error;
+                }
             });
         });
     }

src/model/kubernetes.ts

@@ -339,13 +339,21 @@ class Kubernetes {
       pod.status?.containerStatuses?.[0].containerID,
       true,
     );
+
+    core.info('opening log stream');
+
     await new Promise((resolve, reject) => {
+      try {
         logs.response.on('data', (chunk) => {
           core.info(chunk);
         });
         logs.response.on('close', resolve);
         logs.response.on('error', reject);
         logs.response.on('end', resolve);
+      } catch (error) {
+        core.error(error);
+        throw error;
+      }
     });
   }