fix nullref in scale monitor (#97)

microsoft · Dec 21, 2021 · 3be91de · 3be91de
1 parent b74f132
commit 3be91de
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/DurableTask.Netherite/OrchestrationService/NetheriteOrchestrationService.cs b/src/DurableTask.Netherite/OrchestrationService/NetheriteOrchestrationService.cs
@@ -175,7 +175,8 @@ public bool TryGetScalingMonitor(out ScalingMonitor monitor)
                     this.Settings.ResolvedTransportConnectionString, 
                     this.Settings.LoadInformationAzureTableName, 
                     this.Settings.HubName,
-                    this.TraceHelper.TraceScaleRecommendation);
+                    this.TraceHelper.TraceScaleRecommendation,
+                    this.TraceHelper.Logger);
                 return true;
             }
             else

diff --git a/src/DurableTask.Netherite/Scaling/ScalingMonitor.cs b/src/DurableTask.Netherite/Scaling/ScalingMonitor.cs
@@ -50,13 +50,15 @@ public ScalingMonitor(
             string eventHubsConnectionString, 
             string partitionLoadTableName, 
             string taskHubName,
-            Action<string, int, string> recommendationTracer)
+            Action<string, int, string> recommendationTracer,
+            ILogger logger)
         {
             this.storageConnectionString = storageConnectionString;
             this.eventHubsConnectionString = eventHubsConnectionString;
             this.partitionLoadTableName = partitionLoadTableName;
             this.taskHubName = taskHubName;
             this.recommendationTracer = recommendationTracer;
+            this.Logger = logger;
 
             TransportConnectionString.Parse(eventHubsConnectionString, out _, out this.configuredTransport);