Merge pull request #96 from target/patch/orphan-job-bug

Deleted orphaned job

Author: James Bell

setup.py

@@ -4,7 +4,7 @@
 
 setup(
     name='tgt_grease',
-    version='2.4.0',
+    version='2.4.1',
     license="MIT",
     description='Modern distributed automation engine built with love by Target',
     long_description="""

tgt_grease/management/Model/monitor.py

@@ -281,6 +281,7 @@ def rescheduleDetectJobs(self, serverId):
                 'grease_data.detection.end': None
             }
         ):
+            self.ioc.getCollection('SourceData').delete_one({'_id': ObjectId(job.get('_id'))})
             job = dict(job)
             if not self.centralScheduler.scheduleDetection(job.get('source'), job.get('configuration'), [job]):
                 retval = False
@@ -396,6 +397,7 @@ def schedule_detection_orphans(self):
                 'grease_data.detection.end': None
             }
         ):
+            self.ioc.getCollection('SourceData').delete_one({'_id': ObjectId(orphan.get('_id'))})
             if self.centralScheduler.scheduleDetection(orphan.get('source'), orphan.get('configuration'), [orphan]):
                 self.ioc.getLogger().info(
                     "Rescheduled orphan detection record: [{}]".format(orphan), verbose=True)