feast-dev
diff --git a/‎charts/feast/Chart.yaml‎
Lines changed: 1 addition & 1 deletion b/‎charts/feast/Chart.yaml‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎charts/feast/values.yaml‎
Lines changed: 2 additions & 2 deletions b/‎charts/feast/values.yaml‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎ingestion/src/main/java/feast/ingestion/transform/WriteFeatureMetricsToInfluxDB.java‎
Lines changed: 22 additions & 11 deletions b/‎ingestion/src/main/java/feast/ingestion/transform/WriteFeatureMetricsToInfluxDB.java‎
Lines changed: 22 additions & 11 deletions
@@ -1,5 +1,5 @@
 apiVersion: v1
-appVersion: "0.1.2"
+appVersion: "0.1.4"
 description: A Helm chart to install Feast on kubernetes
 name: feast
 version: 0.1.2
@@ -5,7 +5,7 @@ core:
     pullPolicy: IfNotPresent
     registry: gcr.io/kf-feast
     repository: feast-core
-    tag: "0.1.1"
+    tag: "0.1.4"
   replicaCount: 1
   resources: 
     limits: 
@@ -84,7 +84,7 @@ serving:
     pullPolicy: IfNotPresent
     registry: gcr.io/kf-feast
     repository: feast-serving
-    tag: "0.1.1"
+    tag: "0.1.4"
   replicaCount: 1
   resources: 
     limits: 
 
@@ -15,6 +15,7 @@
 import org.influxdb.InfluxDBFactory;
 import org.influxdb.dto.Point;
 
+@SuppressWarnings("CatchMayIgnoreException")
 public class WriteFeatureMetricsToInfluxDB
     extends PTransform<PCollection<FeatureRowExtended>, PDone> {
 
@@ -38,9 +39,14 @@ public PDone expand(PCollection<FeatureRowExtended> input) {
 
               @Setup
               public void setup() {
-                influxDB = InfluxDBFactory.connect(influxDbUrl);
-                influxDB.setDatabase(influxDbDatabase);
-                influxDB.enableBatch(BatchOptions.DEFAULTS);
+                try {
+                  influxDB = InfluxDBFactory.connect(influxDbUrl);
+                  influxDB.setDatabase(influxDbDatabase);
+                  influxDB.enableBatch(BatchOptions.DEFAULTS);
+                } catch (Exception e) {
+                  // Ignored because writing metrics is not a critical component of Feaast
+                  // and we do not want to get overwhelmed with failed connection logs
+                }
               }
 
               @FinishBundle
@@ -60,14 +66,19 @@ public void processElement(
                       System.currentTimeMillis() / 1000L
                           - featureRow.getEventTimestamp().getSeconds();
                   double value = getValue(feature);
-                  influxDB.write(
-                      Point.measurement(influxDbMeasurement)
-                          .time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
-                          .addField("lag_in_seconds", lagInSeconds)
-                          .addField("value", value)
-                          .tag("feature_id", featureId)
-                          .tag("entity_name", featureRow.getEntityName())
-                          .build());
+                  try {
+                    influxDB.write(
+                        Point.measurement(influxDbMeasurement)
+                            .time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
+                            .addField("lag_in_seconds", lagInSeconds)
+                            .addField("value", value)
+                            .tag("feature_id", featureId)
+                            .tag("entity_name", featureRow.getEntityName())
+                            .build());
+                  } catch (Exception e) {
+                    // Ignored because writing metrics is not a critical component of Feaast
+                    // and we do not want to get overwhelmed with failed connection logs
+                  }
                 }
               }
             }));