From 0409ce13d3933a5ed97db77fc3d97c1a528e39c9 Mon Sep 17 00:00:00 2001 From: Ryan Br Date: Tue, 16 Jul 2024 15:28:46 -0700 Subject: [PATCH] fix: fix metric name and add reset information. (#13129) --- .../io/airbyte/workers/general/ReplicationWorkerHelper.kt | 3 ++- .../src/main/java/io/airbyte/metrics/lib/MetricTags.java | 1 + 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/airbyte-commons-worker/src/main/kotlin/io/airbyte/workers/general/ReplicationWorkerHelper.kt b/airbyte-commons-worker/src/main/kotlin/io/airbyte/workers/general/ReplicationWorkerHelper.kt index 23d120fb3ee..ae91deef71f 100644 --- a/airbyte-commons-worker/src/main/kotlin/io/airbyte/workers/general/ReplicationWorkerHelper.kt +++ b/airbyte-commons-worker/src/main/kotlin/io/airbyte/workers/general/ReplicationWorkerHelper.kt @@ -221,7 +221,7 @@ class ReplicationWorkerHelper( streamStatusCompletionTracker.startTracking(configuredAirbyteCatalog, supportRefreshes) if (configuredAirbyteCatalog.streams.isEmpty()) { - metricClient.count(OssMetricsRegistry.DESTINATION_DESERIALIZATION_ERROR, 1, *metricAttrs.toTypedArray()) + metricClient.count(OssMetricsRegistry.SYNC_WITH_EMPTY_CATALOG, 1, *metricAttrs.toTypedArray()) } } @@ -515,6 +515,7 @@ private fun toConnectionAttrs(ctx: ReplicationContext?): List { ctx.connectionId?.let { add(MetricAttribute(MetricTags.CONNECTION_ID, it.toString())) } ctx.jobId?.let { add(MetricAttribute(MetricTags.JOB_ID, it.toString())) } ctx.attempt?.let { add(MetricAttribute(MetricTags.ATTEMPT_NUMBER, it.toString())) } + add(MetricAttribute(MetricTags.IS_RESET, ctx.isReset.toString())) } } diff --git a/airbyte-metrics/metrics-lib/src/main/java/io/airbyte/metrics/lib/MetricTags.java b/airbyte-metrics/metrics-lib/src/main/java/io/airbyte/metrics/lib/MetricTags.java index af6ca69e8f7..05f1887558f 100644 --- a/airbyte-metrics/metrics-lib/src/main/java/io/airbyte/metrics/lib/MetricTags.java +++ b/airbyte-metrics/metrics-lib/src/main/java/io/airbyte/metrics/lib/MetricTags.java @@ -39,6 +39,7 @@ public class MetricTags { public static final String GEOGRAPHY = "geography"; public static final String IMPLEMENTATION = "implementation"; public static final String IS_CUSTOM_CONNECTOR_SYNC = "is_custom_connector_sync"; + public static final String IS_RESET = "is_reset"; public static final String JOB_ID = "job_id"; public static final String JOB_STATUS = "job_status"; public static final String KILLED = "killed";