Canvas: Persistent log storage
Change-Id: I3eac705329e6d68d8e4b9a371c6e9b9807f357ec
diff --git a/apps/canvas/back/src/project_monitor.ts b/apps/canvas/back/src/project_monitor.ts
index 0f4fffe..4b234a5 100644
--- a/apps/canvas/back/src/project_monitor.ts
+++ b/apps/canvas/back/src/project_monitor.ts
@@ -50,21 +50,8 @@
constructor(public readonly serviceName: string) {}
- registerWorker(
- workerId: string,
- workerAddress: string,
- workerLog?: LogItem[],
- workerStatus?: Worker["status"],
- ): void {
+ registerWorker(workerId: string, workerAddress: string, workerStatus?: Worker["status"]): void {
this.workers.set(workerId, workerAddress);
- if (workerLog) {
- const existingLogs = this.logs.get(workerId);
- if (existingLogs) {
- existingLogs.push(...workerLog);
- } else {
- this.logs.set(workerId, workerLog);
- }
- }
if (workerStatus) {
this.statuses.set(workerId, workerStatus);
}
@@ -133,7 +120,7 @@
serviceMonitor = new ServiceMonitor(workerData.service);
this.serviceMonitors.set(workerData.service, serviceMonitor);
}
- serviceMonitor.registerWorker(workerData.id, workerData.address, workerData.logs, workerData.status);
+ serviceMonitor.registerWorker(workerData.id, workerData.address, workerData.status);
}
getWorkerAddresses(): string[] {