Changeset 6961 for taskscheduler/trunk/fuentes/server-scheduler.install/usr/share/n4d/python-plugins/SchedulerServer.py

Timestamp:

Mar 5, 2018, 1:51:06 PM (3 years ago)

Author:

Juanma

Message:

bugfix autoremove

File:

• taskscheduler/trunk/fuentes/server-scheduler.install/usr/share/n4d/python-plugins/SchedulerServer.py (modified) (3 diffs)

taskscheduler/trunk/fuentes/server-scheduler.install/usr/share/n4d/python-plugins/SchedulerServer.py

@@ -8 +8 @@
 import os
 import json
+from  datetime import date
 
 class SchedulerServer():
         def __init__(self):
-                self.dbg=0
+                self.dbg=1
                 self.tasks_dir="/etc/scheduler/tasks.d"
                 self.schedTasksDir=self.tasks_dir+"/scheduled"
@@ -31 +32 @@
 
         def get_local_tasks(self,*args):
+                today=date.today()
                 local_tasks={}
                 tasks_data=self._read_wrkfiles(self.tasks_dir)['data'].copy()
@@ -37 +39 @@
                         sw_continue=False
                         for serial,data in serial_data.items():
+                                print("DATA: %s"%data)
+                                sw_pass=False
+                                if 'autoremove' in data.keys():
+                                        if (data['mon'].isdigit()):
+                                                mon=int(data['mon'])
+                                                if mon<today.month:
+                                                        sw_pass=True
+                                        if sw_pass==False:
+                                                if (data['dom'].isdigit()):
+                                                        dom=int(data['dom'])
+                                                        if dom<today.day:
+                                                                sw_pass=True
+                                        if sw_pass:
+                                                task={}
+                                                self._debug("Autoremoving %s %s"%(task_name,serial))
+                                                task['name']=task_name
+                                                task['serial']=serial
+                                                self.remove_task(task)
+                                                continue
                                 if 'spread' in data.keys():
                                         if data['spread']==False: