Ignore:
Timestamp:
Feb 14, 2018, 6:10:39 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

    r6811 r6818  
    3535                        sw_continue=False
    3636                        for task in task_serial.keys():
    37                                 if ['spread_task'] in task.keys():
    38                                                 if task['spread_task']==True:
     37                                if ['spread'] in task.keys():
     38                                                if task['spread']==True:
    3939                                                        sw_continue=True
    4040                                                        break
     
    4646        def get_remote_tasks(self):
    4747                remote_tasks={}
    48                 tasks_data=self._read_wrkfiles(self.tasks_dir)['data']
    49                 for task_serial in tasks_data.keys():
     48                tasks_data=self._read_wrkfiles(self.tasks_dir)['data'].copy()
     49
     50                for task_name,serial_data in tasks_data.items():
    5051                        sw_continue=False
    51                         for task in task_serial.keys():
    52                                 if ['spread_task'] in task.keys():
    53                                         if task['spread_task']==True:
    54                                                 remote_tasks.update(task_serial)
    55                                                 break
     52                        for serial,data in serial_data.items():
     53                                if 'spread' in data.keys():
     54                                        if data['spread']==True:
     55                                                if task_name in remote_tasks.keys():
     56#                                                       remote_tasks[task_name].update({'r'+serial:tasks_data[task_name][serial]})
     57                                                        remote_tasks[task_name]['r'+serial]=tasks_data[task_name][serial]
     58                                                else:
     59                                                        remote_tasks[task_name]={'r'+serial:tasks_data[task_name][serial]}
    5660                return remote_tasks
    5761
     
    8589                if os.path.isfile(wrkfile):
    8690                        try:
    87                                 tasks=json.loads(open(wrkfile).read())
    88                         except :
     91#                               with open(wrkfile,"rb") as fh:
     92#                                       tasks=json.load(fh)
     93                                tasks=json.loads(open(wrkfile,"rb").read())
     94                        except Exception as e:
    8995                                errormsg=(("unable to open %s") % wrkfile)
     96                                errormsg=(("Reason: %s") %e)
    9097                                self._debug(errormsg)
    9198                return(tasks)
     
    132139                task_name=list(tasks.keys())[0]
    133140                task_serial=list(tasks[task_name].keys())[0]
     141                task_data=tasks[task_name][task_serial]
     142                del tasks[task_name][task_serial]
     143                task_serial=task_serial.strip("r")
     144                tasks[task_name]={task_serial:task_data}
    134145                self._debug(tasks)
    135146                serialized_task={}
Note: See TracChangeset for help on using the changeset viewer.