Commit 15fe75c3 by Edward Zarecor

small refactoring

parent ec57d8f5
...@@ -34,6 +34,9 @@ class CallbackModule(object): ...@@ -34,6 +34,9 @@ class CallbackModule(object):
app_key=None) app_key=None)
self.datadog_api_initialized = True self.datadog_api_initialized = True
def clean_tag_value(self, value):
return value.replace(" | ", ".").replace(" ", "-").lower()
def playbook_on_play_start(self, pattern): def playbook_on_play_start(self, pattern):
self.playbook_name, _ = os.path.splitext( self.playbook_name, _ = os.path.splitext(
os.path.basename(self.play.playbook.filename) os.path.basename(self.play.playbook.filename)
...@@ -77,16 +80,18 @@ class CallbackModule(object): ...@@ -77,16 +80,18 @@ class CallbackModule(object):
metric="edx.ansible.task_duration", metric="edx.ansible.task_duration",
date_happened=[0], date_happened=[0],
points=points[1], points=points[1],
tags=["task:{0}".format( tags=[
name.replace(" | ", ".").replace(" ", "-").lower())] "task:{0}".format(self.clean_tag_value(name)),
"playbook:{0}".format(
self.clean_tag_value(self.playbook_name))
]
) )
datadog.api.Metric.send( datadog.api.Metric.send(
metric="edx.ansible.playbook_duration", metric="edx.ansible.playbook_duration",
date_happened=time.time(), date_happened=time.time(),
points=total_seconds, points=total_seconds,
tags=["playbook:{0}".format( tags=["playbook:{0}".format(
self.playbook_name.replace(" | ", "."). self.clean_tag_value(self.playbook_name))]
replace(" ", "-").lower())]
) )
# Log the time of each task # Log the time of each task
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment