Ignore:
Timestamp:
Feb 16, 2018, 12:54:54 PM (19 months ago)
Author:
Juanma
Message:

refactorized

File:
1 edited

Legend:

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

    r6824 r6831  
    1111class SchedulerServer():
    1212        def __init__(self):
    13                 self.dbg=0
     13                self.dbg=1
    1414                self.tasks_dir="/etc/scheduler/tasks.d"
    1515                self.schedTasksDir=self.tasks_dir+"/scheduled"
     
    1818                self.remote_tasks_dir=self.tasks_dir+"/remote"
    1919                self.local_tasks_dir=self.tasks_dir+"/local"
     20                self.commands_file='/etc/scheduler/conf.d/commands/commands.json'
    2021        #def __init__
    2122
     
    3233                local_tasks={}
    3334                tasks_data=self._read_wrkfiles(self.tasks_dir)['data'].copy()
    34                 for task_serial in tasks_data.keys():
     35
     36                for task_name,serial_data in tasks_data.items():
    3537                        sw_continue=False
    36                         for task in task_serial.keys():
    37                                 if ['spread'] in task.keys():
    38                                                 if task['spread']==True:
    39                                                         sw_continue=True
    40                                                         break
    41                         if sw_continue:
    42                                 continue
    43                         local_tasks.update(task_serial)
     38                        for serial,data in serial_data.items():
     39                                if 'spread' in data.keys():
     40                                        if data['spread']==False:
     41                                                if task_name in local_tasks.keys():
     42#                                                       remote_tasks[task_name].update({'r'+serial:tasks_data[task_name][serial]})
     43                                                        local_tasks[task_name]['r'+serial]=tasks_data[task_name][serial]
     44                                                else:
     45                                                        local_tasks[task_name]={'r'+serial:tasks_data[task_name][serial]}
     46                                else:
     47                                        if task_name in local_tasks.keys():
     48                                                local_tasks[task_name]['r'+serial]=tasks_data[task_name][serial]
     49                                        else:
     50                                                local_tasks[task_name]={'r'+serial:tasks_data[task_name][serial]}
    4451                return local_tasks
    4552
     
    244251        #def write_custom_task
    245252
     253        def add_command(self,cmd_name,cmd):
     254                self._debug("Adding command %s - %s"%(cmd_name,cmd))
     255                commands={}
     256                dict_cmd={cmd_name:cmd}
     257                if os.path.isfile(self.commands_file):
     258                        commands=json.loads(open(self.commands_file,"rb").read())
     259                commands.update(dict_cmd)
     260                with open(self.commands_file,'w') as json_data:
     261                        json.dump(commands,json_data,indent=4)
     262        #def add_command
     263
    246264        def _register_cron_update(self):
    247265                self._debug("Registering trigger var")
Note: See TracChangeset for help on using the changeset viewer.