Ignore:
Timestamp:
Feb 13, 2018, 4:52:00 PM (19 months ago)
Author:
Juanma
Message:

WIP

File:
1 edited

Legend:

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

    r6763 r6811  
    88import threading
    99import time
     10from  datetime import date
    1011import xmlrpclib as xmlrpc
    1112
     
    4142        def process_tasks(self,data=None):
    4243                self._debug("Scheduling tasks")
     44                today=date.today()
    4345                prefixes={'remote':True,'local':False}
    4446                tasks={}
     
    5254                        else:
    5355                                n4d=xmlrpc.ServerProxy("https://localhost:9779")
    54                         tasks=n4d.get_tasks("","SchedulerServer",sw_remote,False)['data'].copy()
     56                        tasks=n4d.get_tasks("","SchedulerServer")['data'].copy()
     57
    5558                        #Delete files
    5659                        for f in os.listdir(self.cron_dir):
     
    6164                        for name in tasks.keys():
    6265                                for serial in tasks[name].keys():
     66                                        sw_pass=False
     67                                        if 'autoremove' in tasks[name][serial]:
     68                                                if type(tasks[name][serial]['m'])==type(int):
     69                                                        if tasks[name][serial]['m']<today.month:
     70                                                                sw_pass=True
     71                                                if sw_pass==False:
     72                                                        if type(tasks[name][serial]['d'])==type(int):
     73                                                                if tasks[name][serial]['d']<today.day:
     74                                                                        sw_pass=True
     75                                        if sw_pass:
     76                                                continue
    6377                                        self._debug("Scheduling %s"%name)
    6478                                        fname=name.replace(' ','_')
     
    7690                                                        task_data['mon'],task_data['dow'],u""+task_data['cmd']))
    7791                        cron_array.append(cron_task)
    78 #                       for task_serial,task_info in task_data.items():
    79 #                               cron_task=("%s %s %s %s %s root %s"%(task_info['m'],task_info['h'],task_info['dom'],\
    80 #                                                               task_info['mon'],task_info['dow'],task_info['cmd']))
    81 #                               cron_array.append(cron_task)
    8292                        if task_data:
    8393                                with open(fname,'w') as data:
Note: See TracChangeset for help on using the changeset viewer.