Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 2015-02-13 13:41:53,748 [noc.lib.scheduler.scheduler] [inv.discovery] Running scheduler
- 2015-02-13 13:41:53,799 [noc.lib.debug] UNHANDLED EXCEPTION (2015-02-13 13:41:53.759444)
- BRANCH: develop TIP: c8284aa6c6a8
- PROCESS: ./scripts/noc-discovery.py
- ERROR FINGERPRINT: b84ffaa3-763e-5b73-b847-81b28c9ecdee
- WORKING DIRECTORY: /opt/noc
- EXCEPTION: <type 'exceptions.TypeError'> super() argument 1 must be type, not classobj
- START OF TRACEBACK
- ------------------------------------------------------------------------
- File: lib/log.py (Line: 49)
- Function: info
- 42
- 43 def debug(self, msg, *args, **kwargs):
- 44 self._append(msg, args)
- 45 super(TeeLoggerAdapter, self).debug(msg, *args, **kwargs)
- 46
- 47 def info(self, msg, *args, **kwargs):
- 48 self._append(msg, args)
- 49 ==> super(TeeLoggerAdapter, self).info(msg, *args, **kwargs)
- 50
- 51 def warning(self, msg, *args, **kwargs):
- 52 self._append(msg, args)
- 53 super(TeeLoggerAdapter, self).warning(msg, *args, **kwargs)
- 54
- 55 def error(self, msg, *args, **kwargs):
- Variables:
- msg = 'Running job'
- self = <noc.lib.log.TeeLoggerAdapter instance at 0x3efa710>
- args = ()
- kwargs = {}
- ------------------------------------------------------------------------
- File: lib/scheduler/scheduler.py (Line: 268)
- Function: run_job
- 261 job.started = time.time()
- 262 if not job.can_run():
- 263 job.logger.debug("Deferred")
- 264 self._complete_job(job, job.S_DEFERRED, None)
- 265 return
- 266 # Change status
- 267 s = "threaded " if job.threaded else ""
- 268 ==> job.logger.info("Running job")
- 269 self.collection.update({
- 270 self.ATTR_CLASS: job.name,
- 271 self.ATTR_KEY: job.key
- 272 }, {"$set": {
- 273 self.ATTR_STATUS: self.S_RUN,
- 274 self.ATTR_LAST: datetime.datetime.fromtimestamp(job.started)
- Variables:
- s = ''
- job =
- <noc.inv.discovery.jobs.lldp_discovery.LLDPLinkDiscoveryJob object at 0x3e9e690>
- self = <noc.inv.discovery.scheduler.DiscoveryScheduler object at 0x39c9dd0>
- ------------------------------------------------------------------------
- File: lib/scheduler/scheduler.py (Line: 466)
- Function: run_pending
- 459 continue
- 460 # Check for group limits
- 461 group = job.get_group()
- 462 if self.can_run(job):
- 463 if group is not None:
- 464 with self.running_lock:
- 465 self.running_count[group] += 1
- 466 ==> self.run_job(job)
- 467 n += 1
- 468 return n
- 469
- 470 def run(self):
- 471 if self.reset_running:
- 472 # Change running to waiting
- Variables:
- qs = <pymongo.cursor.Cursor object at 0x3e716d0>
- group = 'discovery-170'
- jcls = <class 'noc.inv.discovery.jobs.lldp_discovery.LLDPLinkDiscoveryJob'>
- self = <noc.inv.discovery.scheduler.DiscoveryScheduler object at 0x39c9dd0>
- job_data =
- {u'_id': ObjectId('52f6e86ac0b2cf7c70c22a29'),
- u'data': {},
- u'f': 0,
- u'jcls': u'lldp_discovery',
- u'key': 170,
- u'last': datetime.datetime(2015, 2, 13, 12, 4, 25, 905000),
- u'ldur': 124.29748797416687,
- u'log': [],
- u'ls': u'F',
- u'runs': 3172,
- u's': u'W',
- u'schedule': {u'failed_interval': 600,
- u'interval': 86400,
- u'offset': 0.55145154445139044,
- u'randomize': True},
- u'st': datetime.datetime(2015, 2, 10, 16, 22, 37, 898000),
- u'tb': {u'code': 17, u'text': u'Timed out'},
- u'ts': datetime.datetime(2015, 2, 13, 11, 41, 21, 82000)}
- n = 0
- q =
- {'jcls': {'$nin': ['stp_discovery',
- 'cdp_discovery',
- 'oam_discovery',
- 'bfd_discovery',
- 'rep_discovery',
- 'udld_discovery']},
- 's': 'W',
- 'ts': {'$lte': datetime.datetime(2015, 2, 13, 13, 41, 53, 748913)}}
- job =
- <noc.inv.discovery.jobs.lldp_discovery.LLDPLinkDiscoveryJob object at 0x3e9e690>
- ------------------------------------------------------------------------
- File: lib/scheduler/scheduler.py (Line: 482)
- Function: run
- 475 self.ATTR_STATUS: self.S_RUN
- 476 }, {
- 477 "$set": {self.ATTR_STATUS: self.S_WAIT}
- 478 }, multi=True, safe=True)
- 479 self.ensure_indexes()
- 480 self.logger.info("Running scheduler")
- 481 while True:
- 482 ==> if not self.run_pending():
- 483 time.sleep(1)
- 484 else:
- 485 self.cleanup()
- 486
- 487 def get_faults(self, job_name, key=None):
- 488 """
- Variables:
- self = <noc.inv.discovery.scheduler.DiscoveryScheduler object at 0x39c9dd0>
- ------------------------------------------------------------------------
- File: inv/discovery/daemon.py (Line: 37)
- Function: run
- 30
- 31 def run(self):
- 32 try:
- 33 PerformanceReportJob.submit(self.scheduler,
- 34 key="performance_report", interval=60)
- 35 except self.scheduler.JobExists:
- 36 pass
- 37 ==> self.scheduler.run()
- 38
- 39 def load_config(self):
- 40 super(DiscoveryDaemon, self).load_config()
- 41 self.load_beef_map()
- 42 log_jobs = self.config.get("main", "log_jobs") or None
- 43 self.scheduler.set_job_log(log_jobs)
- Variables:
- self = <noc.inv.discovery.daemon.DiscoveryDaemon object at 0x7feb39126410>
- ------------------------------------------------------------------------
- File: lib/daemon/base.py (Line: 414)
- Function: guarded_run
- 407 :return:
- 408 """
- 409 if self.start_delay:
- 410 self.logger.info("Delaying start for %s seconds",
- 411 self.start_delay)
- 412 time.sleep(self.start_delay)
- 413 try:
- 414 ==> self.run()
- 415 except KeyboardInterrupt:
- 416 pass
- 417 except MemoryError:
- 418 self.logger.error("Out of memory. Exiting.")
- 419 except SystemExit:
- 420 self.logger.info("Exiting")
- Variables:
- self = <noc.inv.discovery.daemon.DiscoveryDaemon object at 0x7feb39126410>
- ------------------------------------------------------------------------
- END OF TRACEBACK
- 2015-02-13 13:41:53,800 [noc-discovery] Removing pidfile: /var/noc/log/run/noc-discovery.pid
- 2015-02-13 13:41:53,800 [noc-discovery] STOP
- ^C
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
