Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- p = {}
- s = ['get_config']
- map_script = 'get_config'
- timeout = 297
- x = <ManagedObject: sic0len77.zap.odeko.hard>
- ------------------------------------------------------------------------
- File: /usr/local/noc/cm/periodics/config_pull.py (Line: 87)
- Function: execute
- 80 (Q(next_pull__lt=datetime.datetime.now()) | Q(next_pull__isnull=True)))
- 81 qs = Config.objects.filter(q).order_by("next_pull")
- 82 if self.concurrency:
- 83 qs = qs[:self.concurrency]
- 84 objects = [o.managed_object for o in qs]
- 85 # @todo: smarter timeout calculation
- 86 task = ReduceTask.create_task(objects, reduce_config_pull, {},
- 87 ==> "get_config", {}, self.timeout - 3)
- 88 return task.get_result(block=True)
- 89
- 90
- Variables:
- qs =
- Config = <class 'noc.cm.models.Config'>
- ------------------------------------------------------------------------
- File: /usr/local/noc/main/scheduler/periodic.py (Line: 74)
- Function: task_wrapper
- 67 t = datetime.datetime.now()
- 68 cwd = os.getcwd()
- 69 try:
- 70 if task.periodic_name.startswith("pyrule:"):
- 71 status = PyRule.call(task.periodic_name[7:],
- 72 timeout=task.timeout)
- 73 else:
- 74 ==> status = task.periodic(task.timeout).execute()
- 75 except:
- 76 error_report()
- 77 status = False
- 78 logging.info(u"Periodic task=%s status=%s" % (unicode(task),
- 79 "completed" if status else "failed"))
- 80 # Current path may be implicitly changed by periodic. Restore old value
- Variables:
- self = <PeriodicScheduler(Thread-1, started daemon 34490205888)>
- task = <Schedule: cm.config_pull:Any>
- cwd = '/usr/local/noc'
- t = datetime.datetime(2013, 3, 11, 11, 12, 36, 817904)
- ------------------------------------------------------------------------
- END OF TRACEBACK
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement