use to_string()

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

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/.astro-registry.yaml b/.astro-registry.yaml
@@ -19,8 +19,8 @@ docs_url: https://github.com/andrewm4894/airflow-provider-anomaly-detection/blob
 # value should be "sample_provider.hooks.sample_hook.SampleHook".
 
 operators:
-  - module: airflow_anomaly_detection.operators.bigquery_metric_batch_ingest_operator.BigQueryMetricBatchIngestOperator
-  - module: airflow_anomaly_detection.operators.bigquery_metric_batch_train_operator.BigQueryMetricBatchTrainOperator
-  - module: airflow_anomaly_detection.operators.bigquery_metric_batch_train_operator.BigQueryMetricBatchScoreOperator
-  - module: airflow_anomaly_detection.operators.bigquery_metric_batch_alert_operator.BigQueryMetricBatchAlertOperator
+  - module: airflow_anomaly_detection.operators.bigquery.metric_batch_ingest_operator.BigQueryMetricBatchIngestOperator
+  - module: airflow_anomaly_detection.operators.bigquery.metric_batch_train_operator.BigQueryMetricBatchTrainOperator
+  - module: airflow_anomaly_detection.operators.bigquery.metric_batch_train_operator.BigQueryMetricBatchScoreOperator
+  - module: airflow_anomaly_detection.operators.bigquery.metric_batch_alert_operator.BigQueryMetricBatchAlertOperator
   - module: airflow_anomaly_detection.operators.metric_batch_alert_operator.MetricBatchEmailNotifyOperator
diff --git a/airflow_anomaly_detection/__init__.py b/airflow_anomaly_detection/__init__.py
@@ -1,5 +1,5 @@
 
-__version__ = "0.0.23"
+__version__ = "0.0.24"
 
 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)
+                    self.log.info(df_scores_tmp.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.23"
+version = "0.0.24"
 authors = [
   { name="andrewm4894", email="[email protected]" },
 ]