Monitor queue adds and EC2 node starts

fixes #157 see #304
2015-09-18 16:21:16 -04:00 · 2015-09-18 16:21:16 -04:00 · bba1557437
commit bba1557437
parent 0316f6e471
2 changed files with 6 additions and 1 deletions
--- a/data/queue.py
+++ b/data/queue.py
@ -127,7 +127,10 @@ class WorkQueue(object):
    params['available_after'] = available_date

    with self._transaction_factory(db):
-      return str(QueueItem.create(**params).id)
+      r = str(QueueItem.create(**params).id)
+      if self._metric_queue:
+        self._metric_queue.put('Added', 1, dimensions={'queue': self._queue_name})
+      return r

  def get(self, processing_time=300):
    """