vbatts/quay
Archived
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Remove unnecessary CloudWatch metrics

Browse source 
They are spamming the API and costing us a lot of money
This commit is contained in:
Joseph Schorr 2017-02-01 13:08:21 -05:00
parent 14093d41ee
commit b407f88a26
5 changed files with 3 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

14
data/queue.py
View file

@ -23,7 +23,6 @@ class BuildMetricQueueReporter(object):
self._metric_queue.build_capacity_shortage.Set(need_capacity_count)
building_percent = 100 if currently_processing else 0
self._metric_queue.put_deprecated('PercentBuilding', building_percent, unit='Percent')
self._metric_queue.percent_building.Set(building_percent)
@ -123,11 +122,6 @@ class WorkQueue(object):
if self._metric_queue:
dim = {'queue': self._queue_name}
self._metric_queue.put_deprecated('Running', running_count, dimensions=dim)
self._metric_queue.put_deprecated('AvailableNotRunning', available_not_running_count,
dimensions=dim)
self._metric_queue.put_deprecated('Available', available_count, dimensions=dim)
self._metric_queue.work_queue_running.Set(running_count, labelvalues=[self._queue_name])
self._metric_queue.work_queue_available.Set(available_count, labelvalues=[self._queue_name])
@ -197,10 +191,6 @@ class WorkQueue(object):
QueueItem.insert_many(remaining[0:batch_size]).execute()
remaining = remaining[batch_size:]
if self._metric_queue:
self._metric_queue.put_deprecated('Added', len(items_to_insert),
dimensions={'queue': self._queue_name})
def put(self, canonical_name_list, message, available_after=0, retries_remaining=5):
"""
Put an item, if it shouldn't be processed for some number of seconds,
@ -208,10 +198,6 @@ class WorkQueue(object):
"""
item = QueueItem.create(**self._queue_dict(canonical_name_list, message, available_after,
retries_remaining))
if self._metric_queue:
self._metric_queue.put_deprecated('Added', 1, dimensions={'queue': self._queue_name})
return str(item.id)
def _select_available_item(self, ordering_required, now):