Changeset 6961


Ignore:
Timestamp:
Mar 5, 2018, 1:51:06 PM (18 months ago)
Author:
Juanma
Message:

bugfix autoremove

Location:
taskscheduler/trunk/fuentes
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • taskscheduler/trunk/fuentes/client-scheduler.install/usr/share/n4d/python-plugins/SchedulerClient.py

    r6958 r6961  
    1717                self.cron_dir='/etc/cron.d'
    1818                self.count=0
    19                 self.dbg=0
    20         #def __init__
     19                self.dbg=1
    2120
    2221        def startup(self,options):
     
    2423                t.daemon=True
    2524                t.start()
    26         #def startup
    2725
    2826        def _debug(self,msg):
    2927                if self.dbg:
    3028                        print(str(msg))
    31         #def _debug
    3229
    3330        def _main_thread(self):
     
    4239                        else:
    4340                                time.sleep(1)
    44         #def _main_thread
    4541
    4642        def process_tasks(self,data=None):
     
    7369                                        sw_pass=False
    7470                                        if 'autoremove' in tasks[name][serial]:
    75                                                 if type(tasks[name][serial]['mon'])==type(int):
    76                                                         if tasks[name][serial]['mon']<today.month:
     71                                                if (tasks[name][serial]['mon'].isdigit()):
     72                                                        mon=int(tasks[name][serial]['mon'])
     73                                                        if mon<today.month:
    7774                                                                sw_pass=True
    7875                                                if sw_pass==False:
    79                                                         if type(tasks[name][serial]['dom'])==type(int):
    80                                                                 if tasks[name][serial]['dom']<today.day:
     76                                                        if (tasks[name][serial]['dom'].isdigit()):
     77                                                                dom=int(tasks[name][serial]['dom'])
     78                                                                if dom<today.day:
    8179                                                                        sw_pass=True
    8280                                        if sw_pass:
     
    8684                                        task_names[fname]=tasks[name][serial].copy()
    8785                                        self._write_crontab_for_task(task_names,prefix)
     86
    8887        #def process_tasks
    8988
  • taskscheduler/trunk/fuentes/server-scheduler.install/usr/share/n4d/python-plugins/SchedulerServer.py

    r6866 r6961  
    88import os
    99import json
     10from  datetime import date
    1011
    1112class SchedulerServer():
    1213        def __init__(self):
    13                 self.dbg=0
     14                self.dbg=1
    1415                self.tasks_dir="/etc/scheduler/tasks.d"
    1516                self.schedTasksDir=self.tasks_dir+"/scheduled"
     
    3132
    3233        def get_local_tasks(self,*args):
     34                today=date.today()
    3335                local_tasks={}
    3436                tasks_data=self._read_wrkfiles(self.tasks_dir)['data'].copy()
     
    3739                        sw_continue=False
    3840                        for serial,data in serial_data.items():
     41                                print("DATA: %s"%data)
     42                                sw_pass=False
     43                                if 'autoremove' in data.keys():
     44                                        if (data['mon'].isdigit()):
     45                                                mon=int(data['mon'])
     46                                                if mon<today.month:
     47                                                        sw_pass=True
     48                                        if sw_pass==False:
     49                                                if (data['dom'].isdigit()):
     50                                                        dom=int(data['dom'])
     51                                                        if dom<today.day:
     52                                                                sw_pass=True
     53                                        if sw_pass:
     54                                                task={}
     55                                                self._debug("Autoremoving %s %s"%(task_name,serial))
     56                                                task['name']=task_name
     57                                                task['serial']=serial
     58                                                self.remove_task(task)
     59                                                continue
    3960                                if 'spread' in data.keys():
    4061                                        if data['spread']==False:
Note: See TracChangeset for help on using the changeset viewer.