Log tasks to remove count.

SvenGroot · Sep 26, 2023 · 80a51f1 · 80a51f1
1 parent 9dbe4c6
commit 80a51f1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/TaskServer/TaskRunner.cs b/src/TaskServer/TaskRunner.cs
@@ -173,6 +173,7 @@ public void CleanupJobTasks(Guid jobID)
                 var tasksToRemove = (from item in _runningTasks
                                      where item.Value.JobId == jobID
                                      select item.Key).ToArray();
+                _log.InfoFormat("Tasks to remove: {0}", tasksToRemove.Length);
                 foreach (var task in tasksToRemove)
                 {
                     if (_runningTasks[task].State == TaskAttemptStatus.Running)

diff --git a/src/TaskServer/TaskServer.cs b/src/TaskServer/TaskServer.cs
@@ -297,7 +297,6 @@ private void ShutdownInternal()
 
         private void SendHeartbeat()
         {
-            _log.Info("Sending heartbeat");
             JetHeartbeatData[] data = null;
             lock (_pendingHeartbeatData)
             {
@@ -309,6 +308,7 @@ private void SendHeartbeat()
             }
 
             JetHeartbeatResponse[] responses = null;
+            _log.Info("Sending heartbeat");
             RpcHelper.TryRemotingCall(() => responses = _jobServer.Heartbeat(LocalAddress, data), _heartbeatInterval, -1);
 
             if (responses != null)