Not-ending learning for anomaly detector #665 (#674)

hastic-zzz · May 20, 2019 · 8074e0a · 8074e0a
1 parent 7bdb2c3
commit 8074e0a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/server/src/controllers/analytics_controller.ts b/server/src/controllers/analytics_controller.ts
@@ -290,6 +290,8 @@ export async function runLearning(id: AnalyticUnit.AnalyticUnitId, from?: number
     if(result.status !== AnalyticUnit.AnalyticUnitStatus.SUCCESS) {
       throw new Error(result.error);
     }
+    // TODO: rename SUCCESS to something better
+    await AnalyticUnit.setStatus(id, AnalyticUnit.AnalyticUnitStatus.SUCCESS);
     await AnalyticUnitCache.setData(id, result.payload.cache);
   } catch (err) {
     const message = err.message || JSON.stringify(err);
@@ -331,8 +333,7 @@ export async function runDetect(id: AnalyticUnit.AnalyticUnitId, from?: number,
       { detector, analyticUnitType, lastDetectionTime: unit.lastDetectionTime, data, cache: oldCache }
     );
     console.log(`run task, id:${id}`);
-    // TODO: status: detection
-    await AnalyticUnit.setStatus(id, AnalyticUnit.AnalyticUnitStatus.LEARNING);
+    await AnalyticUnit.setStatus(id, AnalyticUnit.AnalyticUnitStatus.DETECTION);
     const result = await runTask(task);
 
     if(result.status === AnalyticUnit.AnalyticUnitStatus.FAILED) {

diff --git a/server/src/models/analytic_units/types.ts b/server/src/models/analytic_units/types.ts
@@ -6,6 +6,7 @@ export enum AnalyticUnitStatus {
   READY = 'READY',
   PENDING = 'PENDING',
   LEARNING = 'LEARNING',
+  DETECTION = 'DETECTION',
   SUCCESS = 'SUCCESS',
   FAILED = 'FAILED'
 };