Skip to content

Commit 9f363d1

Browse files
add empty metrics fields
1 parent 4031d4e commit 9f363d1

File tree

3 files changed

+10
-1
lines changed

3 files changed

+10
-1
lines changed

superclient/agent/tracker.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@ def __init__(
3939
self.error = error
4040
self.metadata = metadata
4141
self.topics_env = topics_env or []
42+
self.start_time_ms = int(time.time() * 1000) # Unix timestamp in milliseconds
4243

4344
def record_topic(self, topic: str):
4445
"""Record a topic that this producer writes to."""

superclient/core/reporter.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -150,6 +150,10 @@ def send_clients_msg(tracker: Any, error: str = "") -> None:
150150
most_impactful_topic=tracker.determine_topic(),
151151
language=f"Python ({tracker.library})",
152152
error=error,
153+
producer_metrics={},
154+
topic_metrics={},
155+
node_metrics={},
156+
app_info_metrics={"start-time-ms": str(tracker.start_time_ms)},
153157
)
154158
payload = json.dumps(msg.__dict__).encode()
155159
internal_send_clients(tracker.bootstrap, tracker.orig_cfg, payload, tracker.library)

superclient/model/messages.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,4 +35,8 @@ class ClientMessage:
3535
superstream_client_uid: str = ""
3636
most_impactful_topic: str = ""
3737
language: str = ""
38-
error: str = ""
38+
error: str = ""
39+
producer_metrics: Dict[str, Any] = field(default_factory=dict)
40+
topic_metrics: Dict[str, Any] = field(default_factory=dict)
41+
node_metrics: Dict[str, Any] = field(default_factory=dict)
42+
app_info_metrics: Dict[str, Any] = field(default_factory=dict)

0 commit comments

Comments
 (0)