Added ability to update the taskworker

Author: dei79

dotNet/CoreHelpers.TaskLogging.Abstractions/ITaskLoggerFactory.cs

@@ -62,7 +62,15 @@ public interface ITaskLoggerFactory
         /// <param name="taskId"></param>
         /// <param name="taskStatus"></param>
         /// <returns></returns>
-        Task UpdateTaskStatus(string taskId, TaskStatus taskStatus);        
+        Task UpdateTaskStatus(string taskId, TaskStatus taskStatus);
+        
+        /// <summary>
+        /// Allows to update the worker of a task, especially useful for task reassignment
+        /// </summary>
+        /// <param name="taskId"></param>
+        /// <param name="taskWorker"></param>
+        /// <returns></returns>
+        Task UpdateTaskWorker(string taskId, string taskWorker);
     }
 }
 

dotNet/CoreHelpers.TaskLogging/AzureStorageTableTaskLoggerFactory.cs

@@ -99,6 +99,23 @@ public async Task UpdateTaskStatus(string taskKey, TaskStatus taskStatus)
             }
         }
 
+        public async Task UpdateTaskWorker(string taskId, string taskWorker)
+        {
+            // build the task entity
+            var taskEntity = new AzureTableTaskEntity()
+            {
+                PartitionKey = taskId,
+                RowKey = taskId, 
+                TaskWorker = taskWorker
+            };
+            
+            // get the table name
+            var tableName = GetTaskTable();
+
+            // update the entity
+            await UpdateEntityInTable<AzureTableTaskEntity>(tableName, taskEntity);
+        }
+
         public ITaskLogger CreateTaskLogger(string taskKey)
         {
             return new AzureStorageTableTaskLogger(taskKey, _cacheLimit, _cacheTimespan, this);