Skip to content

Commit 114571a

Browse files
committed
stable job name in row metrics
Signed-off-by: Oleksii Moskalenko <moskalenko.alexey@gmail.com>
1 parent e47903f commit 114571a

1 file changed

Lines changed: 7 additions & 1 deletion

File tree

ingestion/src/main/java/feast/ingestion/transform/metrics/WriteRowMetricsDoFn.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,11 @@
2525
import feast.proto.types.ValueProto.Value;
2626
import feast.proto.types.ValueProto.Value.ValCase;
2727
import java.time.Clock;
28+
import java.util.Arrays;
2829
import java.util.HashMap;
2930
import java.util.Map;
3031
import java.util.Map.Entry;
32+
import java.util.stream.Collectors;
3133
import javax.annotation.Nullable;
3234
import org.apache.beam.sdk.transforms.DoFn;
3335
import org.apache.beam.sdk.values.KV;
@@ -192,11 +194,15 @@ public void processElement(
192194
}
193195
}
194196

197+
String[] split = c.getPipelineOptions().getJobName().split("-");
198+
String jobNameWithoutTimestamp =
199+
Arrays.stream(split).limit(split.length - 1).collect(Collectors.joining("-"));
200+
195201
String[] tags = {
196202
STORE_TAG_KEY + ":" + getStoreName(),
197203
FEATURE_SET_PROJECT_TAG_KEY + ":" + featureSetProject,
198204
FEATURE_SET_NAME_TAG_KEY + ":" + featureSetName,
199-
INGESTION_JOB_NAME_KEY + ":" + c.getPipelineOptions().getJobName(),
205+
INGESTION_JOB_NAME_KEY + ":" + jobNameWithoutTimestamp,
200206
METRICS_NAMESPACE_KEY + ":" + getMetricsNamespace(),
201207
};
202208

0 commit comments

Comments
 (0)