Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <class 'noc.sa.models.reducetask.DoesNotExist'>
- ReduceTask matching query does not exist.
- START OF TRACEBACK
- ------------------------------------------------------------------------
- File: /opt/noc/lib/python2.7/site-packages/django/db/models/query.py (Line: 366)
- Function: get
- 359 if self.query.can_filter():
- 360 clone = clone.order_by()
- 361 num = len(clone)
- 362 if num == 1:
- 363 return clone._result_cache[0]
- 364 if not num:
- 365 raise self.model.DoesNotExist("%s matching query does not exist."
- 366 ==> % self.model._meta.object_name)
- 367 raise self.model.MultipleObjectsReturned("get() returned more than one %s -- it returned %s! Lookup pa
- rameters were %s"
- 368 % (self.model._meta.object_name, num, kwargs))
- 369
- 370 def create(self, **kwargs):
- 371 """
- 372 Creates a new object with the given kwargs, saving it to the database
- Variables:
- clone = []
- num = 0
- self =
- [<ReduceTask: 1729092>, <ReduceTask: 1728637>, <ReduceTask: 1729093>, <ReduceTask: 1727908>, <ReduceTask: 1728638>, <Red
- uceTask: 1728383>, <ReduceTask: 1728639>, <ReduceTask: 1727911>, <ReduceTask: 1728873>, <ReduceTask: 1728640>, <ReduceTa
- sk: 1729094>, <ReduceTask: 1727692>, <ReduceTask: 1729095>, <ReduceTask: 1729096>, <ReduceTask: 1729097>, <ReduceTask: 1
- 729098>, <ReduceTask: 1729099>, <ReduceTask: 1728874>, <ReduceTask: 1729100>, <ReduceTask: 1729101>, '...(remaining elem
- ents truncated)...']
- args = ()
- kwargs = {'id__exact': 1734075}
- ------------------------------------------------------------------------
- File: /opt/noc/lib/python2.7/site-packages/django/db/models/fields/related.py (Line: 350)
- Function: __get__
- 343 raise self.field.rel.to.DoesNotExist
- 344 other_field = self.field.rel.get_related_field()
- 345 if other_field.rel:
- 346 params = {'%s__pk' % self.field.rel.field_name: val}
- 347 else:
- 348 params = {'%s__exact' % self.field.rel.field_name: val}
- 349 qs = self.get_query_set(instance=instance)
- 350 ==> rel_obj = qs.get(**params)
- 351 setattr(instance, self.cache_name, rel_obj)
- 352 return rel_obj
- 353
- 354 def __set__(self, instance, value):
- 355 if instance is None:
- 356 raise AttributeError("%s must be accessed via instance" % self._field.name)
- Variables:
- qs =
- [<ReduceTask: 1729092>, <ReduceTask: 1728637>, <ReduceTask: 1729093>, <ReduceTask: 1727908>, <ReduceTask: 1728638>, <Red
- uceTask: 1728383>, <ReduceTask: 1728639>, <ReduceTask: 1727911>, <ReduceTask: 1728873>, <ReduceTask: 1728640>, <ReduceTa
- sk: 1729094>, <ReduceTask: 1727692>, <ReduceTask: 1729095>, <ReduceTask: 1729096>, <ReduceTask: 1729097>, <ReduceTask: 1
- 729098>, <ReduceTask: 1729099>, <ReduceTask: 1728874>, <ReduceTask: 1729100>, <ReduceTask: 1729101>, '...(remaining elem
- ents truncated)...']
- val = 1734075
- instance = <MapTask: 1744280: s248-3-1.intt DLink.DES21xx.get_interfaces>
- other_field = <django.db.models.fields.AutoField: id>
- self =
- <django.db.models.fields.related.ReverseSingleRelatedObjectDescriptor object at 0x3539d90>
- instance_type = <class 'noc.sa.models.maptask.MapTask'>
- params = {'id__exact': 1734075}
- ------------------------------------------------------------------------
- File: /opt/noc/sa/sae/sae.py (Line: 484)
- Function: process_mrtasks
- 477 for mt in MapTask.objects.filter(
- 478 status="W",
- 479 next_try__lte=t,
- 480 managed_object__activator__shard__is_active=True,
- 481 managed_object__activator__shard__name__in=self.shards
- 482 ).select_related().select_for_update():
- 483 # Check for task timeouts
- 484 ==> if mt.task.stop_time < t:
- 485 mt.status = "F"
- 486 mt.script_result = dict(code=ERR_TIMEOUT, text="Timed out")
- 487 try:
- 488 mt.save()
- 489 except Exception:
- 490 pass # Can raise integrity error if MRT is gone
- Variables:
- map_callback = <function map_callback at 0x4d3d500>
- exec_script = <function exec_script at 0x4d307d0>
- self = <noc.sa.sae.sae.SAE object at 0x7f759b5b6610>
- throttled_shards = set([])
- mt = <MapTask: 1744280: s248-3-1.intt DLink.DES21xx.get_interfaces>
- t = datetime.datetime(2014, 5, 5, 6, 59, 13, 370206)
- sae_mrt_rate = 0
- shard_mrt_rate = {}
- ------------------------------------------------------------------------
- File: /opt/noc/sa/sae/sae.py (Line: 198)
- Function: tick
- 191 Called every second. Performs periodic maintainance
- 192 and runs pending Map/Reduce tasks
- 193 """
- 194 t = time.time()
- 195 reset_queries() # Clear debug SQL log
- 196 if t - self.last_mrtask_check >= self.mrt_schedule_interval:
- 197 # Check Map/Reduce task status
- 198 ==> self.process_mrtasks()
- 199 self.last_mrtask_check = t
- 200 if t - self.last_status_refresh >= self.activator_status_interval:
- 201 self.refresh_activator_status()
- 202
- 203 def write_event(self, data, timestamp=None, managed_object=None):
- 204 """
- Variables:
- self = <noc.sa.sae.sae.SAE object at 0x7f759b5b6610>
- t = 1399258753.370179
- ------------------------------------------------------------------------
- File: /opt/noc/lib/nbsocket/socketfactory.py (Line: 246)
- Function: run
- 239 time.sleep(1)
- 240 last_tick = last_stale = time.time()
- 241 while cond() and not self.to_shutdown:
- 242 self.loop(1)
- 243 t = time.time()
- 244 if self.tick_callback and t - last_tick >= 1:
- 245 try:
- 246 ==> self.tick_callback()
- 247 except Exception:
- 248 error_report()
- 249 logging.info("Restoring from tick() failure")
- 250 last_tick = t
- 251 if t - last_stale >= 1:
- 252 self.close_stale()
- Variables:
- self = <noc.lib.nbsocket.socketfactory.SocketFactory object at 0x24d1490>
- cond = <function <lambda> at 0x3d08848>
- t = 1399258753.370174
- last_stale = 1399258752.27714
- run_forever = True
- last_tick = 1399258752.27714
- ------------------------------------------------------------------------
- END OF TRACEBACK
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
