add project name to validation metric

Signed-off-by: Oleksii Moskalenko <moskalenko.alexey@gmail.com>

Author: pyalex

sdk/python/feast/contrib/validation/ge.py

@@ -131,6 +131,7 @@ def udf(df: pd.DataFrame) -> pd.Series:
                 value=unexpected_count,
                 tags=[
                     f"feature_table:{os.getenv('FEAST_INGESTION_FEATURE_TABLE', 'unknown')}",
+                    f"project:{os.getenv('FEAST_INGESTION_PROJECT_NAME', 'default')}",
                     f"check:{check_name}",
                 ],
             )

spark/ingestion/src/main/scala/feast/ingestion/StreamingPipeline.scala

@@ -176,7 +176,8 @@ object StreamingPipeline extends BasePipeline with Serializable {
           Map(
             "STATSD_HOST"                   -> c.host,
             "STATSD_PORT"                   -> c.port.toString,
-            "FEAST_INGESTION_FEATURE_TABLE" -> config.featureTable.name
+            "FEAST_INGESTION_FEATURE_TABLE" -> config.featureTable.name,
+            "FEAST_INGESTION_PROJECT_NAME"  -> config.featureTable.project
           )
         case _ => Map.empty[String, String]
       }

tests/e2e/test_validation.py

@@ -200,7 +200,8 @@ def test_validation_reports_metrics(
 
     expected_metrics = [
         (
-            f"feast_feature_validation_check_failed#check:{check_name},feature_table:validation_ge_metrics",
+            f"feast_feature_validation_check_failed#check:{check_name},"
+            f"feature_table:{feature_table.name},project:{feast_client.project}",
             value,
         )
         for check_name, value in unexpected_counts.items()