From 4cba5b93ad29935934cc7c30648c933ddb453726 Mon Sep 17 00:00:00 2001 From: Andrew Maguire Date: Sat, 17 Jun 2023 21:25:55 +0100 Subject: [PATCH] transpose scores when logging --- airflow_anomaly_detection/__init__.py | 2 +- .../operators/bigquery/metric_batch_score_operator.py | 2 +- pyproject.toml | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/airflow_anomaly_detection/__init__.py b/airflow_anomaly_detection/__init__.py index b124c8e..07e8644 100644 --- 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 index dcb8042..6faa1c3 100644 --- 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 index 2370d53..6f4abaf 100644 --- 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="andrewm4894@gmail.com" }, ]