Merge pull request #34 from andrewm4894/bigquery-operator-submodule

refactor bigquery into submodule
andrewm4894 · Jun 17, 2023 · 3829fb3 · 3829fb3
2 parents c586df4 + 7ee9549
commit 3829fb3
Show file tree

Hide file tree

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

diff --git a/...y_detection/example_dags/bigquery_anomaly_detection_dag/bigquery_anomaly_detection_dag.py b/...y_detection/example_dags/bigquery_anomaly_detection_dag/bigquery_anomaly_detection_dag.py
@@ -15,10 +15,10 @@
 import pendulum
 import yaml
 from airflow.decorators import dag
-from airflow_anomaly_detection.operators.bigquery_metric_batch_ingest_operator import BigQueryMetricBatchIngestOperator
-from airflow_anomaly_detection.operators.bigquery_metric_batch_train_operator import BigQueryMetricBatchTrainOperator
-from airflow_anomaly_detection.operators.bigquery_metric_batch_score_operator import BigQueryMetricBatchScoreOperator
-from airflow_anomaly_detection.operators.bigquery_metric_batch_alert_operator import BigQueryMetricBatchAlertOperator
+from airflow_anomaly_detection.operators.bigquery.metric_batch_ingest_operator import BigQueryMetricBatchIngestOperator
+from airflow_anomaly_detection.operators.bigquery.metric_batch_train_operator import BigQueryMetricBatchTrainOperator
+from airflow_anomaly_detection.operators.bigquery.metric_batch_score_operator import BigQueryMetricBatchScoreOperator
+from airflow_anomaly_detection.operators.bigquery.metric_batch_alert_operator import BigQueryMetricBatchAlertOperator
 from airflow_anomaly_detection.operators.metric_batch_email_notify_operator import MetricBatchEmailNotifyOperator
 from airflow_anomaly_detection.utils import get_metric_batch_configs
 

diff --git a/...s/bigquery_metric_batch_alert_operator.py → ...s/bigquery/metric_batch_alert_operator.py b/...s/bigquery_metric_batch_alert_operator.py → ...s/bigquery/metric_batch_alert_operator.py
diff --git a/.../bigquery_metric_batch_ingest_operator.py → .../bigquery/metric_batch_ingest_operator.py b/.../bigquery_metric_batch_ingest_operator.py → .../bigquery/metric_batch_ingest_operator.py
diff --git a/...s/bigquery_metric_batch_score_operator.py → ...s/bigquery/metric_batch_score_operator.py b/...s/bigquery_metric_batch_score_operator.py → ...s/bigquery/metric_batch_score_operator.py
diff --git a/...s/bigquery_metric_batch_train_operator.py → ...s/bigquery/metric_batch_train_operator.py b/...s/bigquery_metric_batch_train_operator.py → ...s/bigquery/metric_batch_train_operator.py
diff --git a/airflow_anomaly_detection/tests/operators/test_bigquery_metric_batch_alert_operator.py b/airflow_anomaly_detection/tests/operators/test_bigquery_metric_batch_alert_operator.py
@@ -1,7 +1,7 @@
 import unittest
 from unittest.mock import patch, MagicMock
 from pandas import DataFrame
-from airflow_anomaly_detection.operators.bigquery_metric_batch_alert_operator import BigQueryMetricBatchAlertOperator
+from airflow_anomaly_detection.operators.bigquery.metric_batch_alert_operator import BigQueryMetricBatchAlertOperator
 
 class TestBigQueryMetricBatchAlertOperator(unittest.TestCase):
 

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.21"
+version = "0.0.22"
 authors = [
   { name="andrewm4894", email="[email protected]" },
 ]