Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- (dp1
- S'component'
- p2
- S'noc-sae'
- p3
- sS'source'
- p4
- S'system'
- p5
- sS'traceback'
- p6
- VUNHANDLED EXCEPTION (2014-04-24 16:27:36.701064)\u000aWorking directory: /opt/noc\u000a<class 'noc.sa.models.reducetask.DoesNotExist'>\u000aReduceTask matching query does not exist.\u000aSTART OF TRACEBACK\u000a------------------------------------------------------------------------\u000aFile: /opt/noc/lib/python2.7/site-packages/django/db/models/query.py (Line: 366)\u000aFunction: get\u000a 359 if self.query.can_filter():\u000a 360 clone = clone.order_by()\u000a 361 num = len(clone)\u000a 362 if num == 1:\u000a 363 return clone._result_cache[0]\u000a 364 if not num:\u000a 365 raise self.model.DoesNotExist("%s matching query does not exist."\u000a 366 ==> % self.model._meta.object_name)\u000a 367 raise self.model.MultipleObjectsReturned("get() returned more than one %s -- it returned %s! Lookup parameters were %s"\u000a 368 % (self.model._meta.object_name, num, kwargs))\u000a 369 \u000a 370 def create(self, **kwargs):\u000a 371 """\u000a 372 Creates a new object with the given kwargs, saving it to the database\u000aVariables:\u000a clone = []\u000a num = 0\u000a self = \u000a[<ReduceTask: 2906258>, <ReduceTask: 2906259>, <ReduceTask: 2906260>, <ReduceTask: 2906261>, <ReduceTask: 2906262>, <ReduceTask: 2906263>, <ReduceTask: 2906264>, <ReduceTask: 2906265>, <ReduceTask: 2290851>, <ReduceTask: 2290852>, <ReduceTask: 2906266>, <ReduceTask: 2906267>, <ReduceTask: 2906268>, <ReduceTask: 2906269>, <ReduceTask: 2906270>, <ReduceTask: 2906271>, <ReduceTask: 2906272>, <ReduceTask: 2906273>, <ReduceTask: 2906274>, <ReduceTask: 2906275>, '...(remaining elements truncated)...']\u000a args = ()\u000a kwargs = {'id__exact': 2914455}\u000a------------------------------------------------------------------------\u000aFile: /opt/noc/lib/python2.7/site-packages/django/db/models/fields/related.py (Line: 350)\u000aFunction: __get__\u000a 343 raise self.field.rel.to.DoesNotExist\u000a 344 other_field = self.field.rel.get_related_field()\u000a 345 if other_field.rel:\u000a 346 params = {'%s__pk' % self.field.rel.field_name: val}\u000a 347 else:\u000a 348 params = {'%s__exact' % self.field.rel.field_name: val}\u000a 349 qs = self.get_query_set(instance=instance)\u000a 350 ==> rel_obj = qs.get(**params)\u000a 351 setattr(instance, self.cache_name, rel_obj)\u000a 352 return rel_obj\u000a 353 \u000a 354 def __set__(self, instance, value):\u000a 355 if instance is None:\u000a 356 raise AttributeError("%s must be accessed via instance" % self._field.name)\u000aVariables:\u000a qs = \u000a[<ReduceTask: 2906258>, <ReduceTask: 2906259>, <ReduceTask: 2906260>, <ReduceTask: 2906261>, <ReduceTask: 2906262>, <ReduceTask: 2906263>, <ReduceTask: 2906264>, <ReduceTask: 2906265>, <ReduceTask: 2290851>, <ReduceTask: 2290852>, <ReduceTask: 2906266>, <ReduceTask: 2906267>, <ReduceTask: 2906268>, <ReduceTask: 2906269>, <ReduceTask: 2906270>, <ReduceTask: 2906271>, <ReduceTask: 2906272>, <ReduceTask: 2906273>, <ReduceTask: 2906274>, <ReduceTask: 2906275>, '...(remaining elements truncated)...']\u000a val = 2914455\u000a instance = <MapTask: 2960130: NV_X10a_S1_10.15.37.21 DLink.DxS.get_ip_discovery>\u000a other_field = <django.db.models.fields.AutoField: id>\u000a self = \u000a<django.db.models.fields.related.ReverseSingleRelatedObjectDescriptor object at 0x2a76990>\u000a instance_type = <class 'noc.sa.models.maptask.MapTask'>\u000a params = {'id__exact': 2914455}\u000a------------------------------------------------------------------------\u000aFile: /opt/noc/sa/sae/sae.py (Line: 484)\u000aFunction: process_mrtasks\u000a 477 for mt in MapTask.objects.filter(\u000a 478 status="W",\u000a 479 next_try__lte=t,\u000a 480 managed_object__activator__shard__is_active=True,\u000a 481 managed_object__activator__shard__name__in=self.shards\u000a 482 ).select_related().select_for_update():\u000a 483 # Check for task timeouts\u000a 484 ==> if mt.task.stop_time < t:\u000a 485 mt.status = "F"\u000a 486 mt.script_result = dict(code=ERR_TIMEOUT, text="Timed out")\u000a 487 try:\u000a 488 mt.save()\u000a 489 except Exception:\u000a 490 pass # Can raise integrity error if MRT is gone\u000aVariables:\u000a map_callback = <function map_callback at 0x4d41050>\u000a s_id = 1\u000a exec_script = <function exec_script at 0x4d41578>\u000a sr = 1\u000a self = <noc.sa.sae.sae.SAE object at 0x7fd12e7e0490>\u000a throttled_shards = set([])\u000a mt = <MapTask: 2960130: NV_X10a_S1_10.15.37.21 DLink.DxS.get_ip_discovery>\u000a t = datetime.datetime(2014, 4, 24, 16, 27, 33, 139110)\u000a sae_mrt_rate = 2\u000a shard_mrt_rate = {1: 1, 3: 1}\u000a------------------------------------------------------------------------\u000aFile: /opt/noc/sa/sae/sae.py (Line: 198)\u000aFunction: tick\u000a 191 Called every second. Performs periodic maintainance\u000a 192 and runs pending Map/Reduce tasks\u000a 193 """\u000a 194 t = time.time()\u000a 195 reset_queries() # Clear debug SQL log\u000a 196 if t - self.last_mrtask_check >= self.mrt_schedule_interval:\u000a 197 # Check Map/Reduce task status\u000a 198 ==> self.process_mrtasks()\u000a 199 self.last_mrtask_check = t\u000a 200 if t - self.last_status_refresh >= self.activator_status_interval:\u000a 201 self.refresh_activator_status()\u000a 202 \u000a 203 def write_event(self, data, timestamp=None, managed_object=None):\u000a 204 """\u000aVariables:\u000a self = <noc.sa.sae.sae.SAE object at 0x7fd12e7e0490>\u000a t = 1398335253.139089\u000a------------------------------------------------------------------------\u000aFile: /opt/noc/lib/nbsocket/socketfactory.py (Line: 246)\u000aFunction: run\u000a 239 time.sleep(1)\u000a 240 last_tick = last_stale = time.time()\u000a 241 while cond() and not self.to_shutdown:\u000a 242 self.loop(1)\u000a 243 t = time.time()\u000a 244 if self.tick_callback and t - last_tick >= 1:\u000a 245 try:\u000a 246 ==> self.tick_callback()\u000a 247 except Exception:\u000a 248 error_report()\u000a 249 logging.info("Restoring from tick() failure")\u000a 250 last_tick = t\u000a 251 if t - last_stale >= 1:\u000a 252 self.close_stale()\u000aVariables:\u000a self = <noc.lib.nbsocket.socketfactory.SocketFactory object at 0x1a13290>\u000a cond = <function <lambda> at 0x3240ed8>\u000a t = 1398335253.139085\u000a last_stale = 1398335248.77626\u000a run_forever = True\u000a last_tick = 1398335248.77626\u000a------------------------------------------------------------------------\u000aEND OF TRACEBACK
- p7
- sS'type'
- p8
- S'Unhandled Exception'
- p9
- sS'ts'
- p10
- I1398335256
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
