Changeset 12776 for branches/HiveStatistics/sources/HeuristicLab.Services.Hive

Timestamp:

07/17/15 16:57:22 (9 years ago)

Author:

dglaser

Message:

#2388:

HeuristicLab.Services.Hive-3.3:

• HiveStatisticsGenerator.cs: Jobs that are deleted are now automatically marked as completed in the hive statistics tables. This was added because when a job got paused and deleted afterwards, it would still show up as ongoing job in the hive statistics.
• Minor changes in NewHiveService.cs

HeuristicLab.Services.WebApp.Statistics-3.3:

• Expired slaves are now shown as offline (previously the last known state was shown)
• Adjusted dialog height

HeuristicLab.Services.WebApp-3.3:

• Changed string.Format to Path.Combine to concate directory paths

Location:

branches/HiveStatistics/sources/HeuristicLab.Services.Hive/3.3

Files:

• HiveStatisticsGenerator.cs (modified) (2 diffs)
• NewHiveService.cs (modified) (17 diffs)

branches/HiveStatistics/sources/HeuristicLab.Services.Hive/3.3/HiveStatisticsGenerator.cs

@@ -134 +134 @@
 
     private void UpdateExistingDimJobs(PersistenceManager pm) {
+      var jobDao = pm.JobDao;
       var dimJobDao = pm.DimJobDao;
       var factTaskDao = pm.FactTaskDao;
@@ -151 +152 @@
         }
         if (totalTasks == completedTasks) {
-          dimJob.DateCompleted = factTaskDao.GetLastCompletedTaskFromJob(dimJob.JobId) ?? DateTime.Now;
+          var completeDate = factTaskDao.GetLastCompletedTaskFromJob(dimJob.JobId);
+          if (completeDate == null) {
+            if (jobDao.GetById(dimJob.JobId) == null) {
+              completeDate = DateTime.Now;
+            }
+          }
+          dimJob.DateCompleted = completeDate;
         }
         dimJob.TotalTasks = totalTasks;

branches/HiveStatistics/sources/HeuristicLab.Services.Hive/3.3/NewHiveService.cs

@@ -128 +128 @@
     }
 
-    public IEnumerable<Task> GetTasks() {
+    public IEnumerable<DT.Task> GetTasks() {
       // unused
       throw new NotImplementedException();
     }
 
-    public IEnumerable<LightweightTask> GetLightweightTasks(IEnumerable<Guid> taskIds) {
+    public IEnumerable<DT.LightweightTask> GetLightweightTasks(IEnumerable<Guid> taskIds) {
       // unused
       throw new NotImplementedException();
     }
 
-    public IEnumerable<LightweightTask> GetLightweightChildTasks(Guid? parentTaskId, bool recursive, bool includeParent) {
+    public IEnumerable<DT.LightweightTask> GetLightweightChildTasks(Guid? parentTaskId, bool recursive, bool includeParent) {
       // unused
       throw new NotImplementedException();
@@ -398 +398 @@
     }
 
-    public IEnumerable<Job> GetAllJobs() {
+    public IEnumerable<DT.Job> GetAllJobs() {
       // unused
       throw new NotImplementedException();
     }
 
-    public Guid AddJob(Job jobDto) {
+    public Guid AddJob(DT.Job jobDto) {
       RoleVerifier.AuthenticateForAnyRole(HiveRoles.Administrator, HiveRoles.Client);
       using (var pm = PersistenceManager)
       using (new PerformanceLogger("AddJob")) {
         var jobDao = pm.JobDao;
+        var userPriorityDao = pm.UserPriorityDao;
         return pm.UseTransaction(() => {
           jobDto.OwnerUserId = UserManager.CurrentUserId;
           jobDto.DateCreated = DateTime.Now;
           var job = jobDao.Save(jobDto.ToEntity());
+          if (userPriorityDao.GetById(jobDto.OwnerUserId) == null) {
+            userPriorityDao.Save(new DA.UserPriority {
+              UserId = jobDto.OwnerUserId,
+              DateEnqueued = jobDto.DateCreated
+            });
+          }
           pm.SubmitChanges();
           return job.JobId;
@@ -447 +454 @@
         var jobDao = pm.JobDao;
         pm.UseTransaction(() => {
+          // child task will be deleted by db-trigger
           jobDao.Delete(jobId);
           pm.SubmitChanges();
@@ -546 +554 @@
 
     #region Heartbeat Methods
-    public List<MessageContainer> Heartbeat(Heartbeat heartbeat) {
+    public List<MessageContainer> Heartbeat(DT.Heartbeat heartbeat) {
       RoleVerifier.AuthenticateForAnyRole(HiveRoles.Slave);
       List<MessageContainer> result = new List<MessageContainer>();
@@ -565 +573 @@
 
     #region Plugin Methods
-    public Plugin GetPlugin(Guid pluginId) {
+    public DT.Plugin GetPlugin(Guid pluginId) {
       RoleVerifier.AuthenticateForAnyRole(HiveRoles.Administrator, HiveRoles.Client, HiveRoles.Slave);
       using (var pm = PersistenceManager)
@@ -574 +582 @@
     }
 
-    public Plugin GetPluginByHash(byte[] hash) {
+    public DT.Plugin GetPluginByHash(byte[] hash) {
       // unused
       throw new NotImplementedException();
     }
 
-    public Guid AddPlugin(Plugin plugin, List<PluginData> pluginData) {
+    public Guid AddPlugin(DT.Plugin plugin, List<DT.PluginData> pluginData) {
       RoleVerifier.AuthenticateForAnyRole(HiveRoles.Administrator, HiveRoles.Client);
       using (var pm = PersistenceManager)
@@ -593 +601 @@
           pluginEntity = plugin.ToEntity();
           foreach (var data in pluginData) {
-            data.PluginId = default(Guid);
+            data.PluginId = default(Guid); // real id will be assigned from linq2sql
             pluginEntity.PluginData.Add(data.ToEntity());
           }
@@ -603 +611 @@
     }
 
-    public IEnumerable<Plugin> GetPlugins() {
+    public IEnumerable<DT.Plugin> GetPlugins() {
       RoleVerifier.AuthenticateForAnyRole(HiveRoles.Administrator, HiveRoles.Client, HiveRoles.Slave);
       using (var pm = PersistenceManager)
@@ -616 +624 @@
     }
 
-    public IEnumerable<PluginData> GetPluginDatas(List<Guid> pluginIds) {
+    public IEnumerable<DT.PluginData> GetPluginDatas(List<Guid> pluginIds) {
       RoleVerifier.AuthenticateForAnyRole(HiveRoles.Administrator, HiveRoles.Client, HiveRoles.Slave);
       using (var pm = PersistenceManager)
@@ -668 +676 @@
     }
 
-    public IEnumerable<ResourcePermission> GetResourcePermissions(Guid resourceId) {
+    public IEnumerable<DT.ResourcePermission> GetResourcePermissions(Guid resourceId) {
       RoleVerifier.AuthenticateForAnyRole(HiveRoles.Administrator, HiveRoles.Client);
       using (var pm = PersistenceManager)
@@ -682 +690 @@
 
     #region Resource Methods
-    public IEnumerable<Resource> GetChildResources(Guid resourceId) {
+    public IEnumerable<DT.Resource> GetChildResources(Guid resourceId) {
       // unused
       throw new NotImplementedException();
@@ -718 +726 @@
     }
 
-    public Slave GetSlave(Guid slaveId) {
+    public DT.Slave GetSlave(Guid slaveId) {
       RoleVerifier.AuthenticateForAnyRole(HiveRoles.Administrator);
       using (var pm = PersistenceManager)
@@ -727 +735 @@
     }
 
-    public SlaveGroup GetSlaveGroup(Guid slaveGroupId) {
+    public DT.SlaveGroup GetSlaveGroup(Guid slaveGroupId) {
       // unused
       throw new NotImplementedException();
     }
 
-    public IEnumerable<Slave> GetSlaves() {
+    public IEnumerable<DT.Slave> GetSlaves() {
       RoleVerifier.AuthenticateForAnyRole(HiveRoles.Administrator, HiveRoles.Client);
       bool isAdministrator = RoleVerifier.IsInRole(HiveRoles.Administrator);
@@ -757 +765 @@
     }
 
-    public IEnumerable<SlaveGroup> GetSlaveGroups() {
+    public IEnumerable<DT.SlaveGroup> GetSlaveGroups() {
       RoleVerifier.AuthenticateForAnyRole(HiveRoles.Administrator, HiveRoles.Client);
       bool isAdministrator = RoleVerifier.IsInRole(HiveRoles.Administrator);
@@ -878 +886 @@
     }
 
-    public IEnumerable<Task> GetTasksByResourceId(Guid resourceId) {
+    public IEnumerable<DT.Task> GetTasksByResourceId(Guid resourceId) {
       // unused
       throw new NotImplementedException();
@@ -967 +975 @@
     }
 
-    public IEnumerable<Downtime> GetDowntimesForResource(Guid resourceId) {
+    public IEnumerable<DT.Downtime> GetDowntimesForResource(Guid resourceId) {
       RoleVerifier.AuthenticateForAnyRole(HiveRoles.Administrator, HiveRoles.Client);
       using (var pm = PersistenceManager)
@@ -995 +1003 @@
 
     #region UserPriorities Methods
-    public IEnumerable<UserPriority> GetUserPriorities() {
+    public IEnumerable<DT.UserPriority> GetUserPriorities() {
       using (var pm = PersistenceManager)
       using (new PerformanceLogger("GetUserPriorities")) {