transpose scores when logging

andrewm4894 · Jun 17, 2023 · 4cba5b9 · 4cba5b9
1 parent 0533107
commit 4cba5b9
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/airflow_anomaly_detection/__init__.py b/airflow_anomaly_detection/__init__.py
@@ -1,5 +1,5 @@
 
-__version__ = "0.0.24"
+__version__ = "0.0.25"
 
 def get_provider_info():
     return {

diff --git a/airflow_anomaly_detection/operators/bigquery/metric_batch_score_operator.py b/airflow_anomaly_detection/operators/bigquery/metric_batch_score_operator.py
@@ -78,7 +78,7 @@ def execute(self, context: Any):
                 df_scores_tmp['metric_timestamp'] = df_X['metric_timestamp'].values
 
                 if context['params'].get('log_scores', False):
-                    self.log.info(df_scores_tmp.to_string())
+                    self.log.info(df_scores_tmp.transpose().to_string())
 
                 # append to df_scores
                 df_scores = df_scores.append(df_scores_tmp)

diff --git a/pyproject.toml b/pyproject.toml
@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "airflow-provider-anomaly-detection"
-version = "0.0.24"
+version = "0.0.25"
 authors = [
   { name="andrewm4894", email="[email protected]" },
 ]