diff --git a/server/src/services/analytic_service/analytic_service.rs b/server/src/services/analytic_service/analytic_service.rs
index 423a22a..5da94e6 100644
--- a/server/src/services/analytic_service/analytic_service.rs
+++ b/server/src/services/analytic_service/analytic_service.rs
@@ -159,6 +159,7 @@ impl AnalyticService {
         ms: MetricService,
         ss: SegmentsService,
     ) {
+        
         match tx
             .send(AnalyticServiceMessage::Response(
                 ResponseType::LearningStarted,
@@ -199,6 +200,10 @@ impl AnalyticService {
         // TODO: save learning results in cache
         let mut learn_tss = Vec::new();
         for r in rs {
+            if r.is_err() {
+                println!("Error extracting metrics from datasource");
+                return;
+            }
             let mr = r.unwrap();
             if mr.data.keys().len() == 0 {
                 continue;
diff --git a/server/src/services/analytic_service/types.rs b/server/src/services/analytic_service/types.rs
index 54d0828..c84d65c 100644
--- a/server/src/services/analytic_service/types.rs
+++ b/server/src/services/analytic_service/types.rs
@@ -30,6 +30,7 @@ pub struct DetectionTask {
 
 #[derive(Debug)]
 pub enum RequestType {
+    // TODO: convert to result RunLearning(anyhow::Result<()>)
     RunLearning,
     RunDetection(DetectionTask),
     GetStatus(oneshot::Sender<LearningStatus>),