Fixes formatting issues.

canvas-medical · Jun 20, 2024 · fc76a5c · fc76a5c
1 parent a8a8ec5
commit fc76a5c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/canvas_sdk/utils/stats.py b/canvas_sdk/utils/stats.py
@@ -1,4 +1,5 @@
 from time import time
+from typing import Any
 
 
 def get_duration_ms(start_time: time) -> int:

diff --git a/plugin_runner/plugin_runner.py b/plugin_runner/plugin_runner.py
@@ -72,8 +72,9 @@ async def HandleEvent(self, request: Event, context):
                 effects = await asyncio.get_running_loop().run_in_executor(None, protocol.compute)
                 compute_duration = get_duration_ms(compute_start_time)
                 log.info(f"{plugin_name}.compute() completed ({compute_duration} ms)")
+                statsd_tags = tags_to_line_protocol({"plugin": plugin_name})
                 self.statsd_client.timing(
-                    f"plugins.protocol_duration_ms,{tags_to_line_protocol({"plugin": plugin_name})}",
+                    f"plugins.protocol_duration_ms,{statsd_tags}",
                     delta=compute_duration,
                 )
             except Exception as e:
@@ -85,8 +86,9 @@ async def HandleEvent(self, request: Event, context):
         # Don't log anything if a protocol didn't actually run.
         if relevant_plugins:
             log.info(f"Responded to Event {event_name} ({event_duration} ms)")
+            statsd_tags = tags_to_line_protocol({"event": event_name})
             self.statsd_client.timing(
-                f"plugins.event_duration_ms,{tags_to_line_protocol({"event": event_name})}",
+                f"plugins.event_duration_ms,{statsd_tags}",
                 delta=event_duration,
             )
         yield EventResponse(success=True, effects=effect_list)