Store/Send insights during/after backtest according to "store-insight…

…s" setting in the config to be more time and disk space friendly.
masq6r · Nov 24, 2023 · 6c88584 · 6c88584
1 parent 579315e
commit 6c88584
Showing 1 changed file with 16 additions and 9 deletions.
diff --git a/Engine/Results/BacktestingResultHandler.cs b/Engine/Results/BacktestingResultHandler.cs
@@ -380,7 +380,11 @@ protected void SendFinalResult()
                 result.DateFinished = DateTime.Now;
                 result.Progress = 1;
 
-                StoreInsights();
+                var shouldStoreInsights = Config.GetBool("store-insights", true);
+                if(shouldStoreInsights)
+                {
+                    StoreInsights();
+                }
 
                 //Place result into storage.
                 StoreResult(result);
@@ -390,14 +394,17 @@ protected void SendFinalResult()
                 MessagingHandler.Send(result);
 
                 // Send the complete list of Insights.
-                var insights =
-                    Algorithm.Insights is null
-                    ? new List<Insight>()
-                    : Algorithm.Insights.GetInsights()
-                        .OrderBy(insight => insight.GeneratedTimeUtc)
-                        .ToList();
-                var alphaPacket = new AlphaResultPacket(Algorithm.AlgorithmId, _job.UserId, insights);
-                MessagingHandler.Send(alphaPacket);
+                if(shouldStoreInsights)
+                {
+                    var insights =
+                        Algorithm.Insights is null
+                        ? new List<Insight>()
+                        : Algorithm.Insights.GetInsights()
+                            .OrderBy(insight => insight.GeneratedTimeUtc)
+                            .ToList();
+                    var alphaPacket = new AlphaResultPacket(Algorithm.AlgorithmId, _job.UserId, insights);
+                    MessagingHandler.Send(alphaPacket);
+                }
 
                 Log.Trace("BacktestingResultHandler.SendAnalysisResult(): Processed final packet");
             }