Add mock_pipeline_test to GHA

danielvdende · Sep 11, 2023 · 6d9c312 · 6d9c312
1 parent 52fd668
commit 6d9c312
Show file tree

Hide file tree

Showing 3 changed files with 57 additions and 21 deletions.
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -3,35 +3,57 @@ on:
   push
 
 jobs:
-  lint:
+#  lint:
+#    runs-on: ubuntu-latest
+#    steps:
+#      - uses: actions/checkout@v3
+#
+#      - uses: actions/setup-python@v4
+#        with:
+#          python-version: '3.10'
+#
+#      - name: Install flake8
+#        run: pip install flake8
+#
+#      - name: Run flake8
+#        run: flake8 dags/
+#
+#  integrity_test:
+#    runs-on: ubuntu-latest
+#    steps:
+#      - uses: actions/checkout@v3
+#
+#      - uses: actions/setup-python@v4
+#        with:
+#          python-version: '3.10'
+#
+#      - name: Install integrity test requirements
+#        run: pip install -r integrity_tests/requirements.txt
+#
+#      - name: Initialize Airflow DB
+#        run: airflow db init
+#
+#      - name: Run integrity tests
+#        run: coverage run -m pytest integrity_tests/*
+
+  mock_pipeline_test:
     runs-on: ubuntu-latest
+#    needs:
+#      - lint
+#      - integrity_test
     steps:
       - uses: actions/checkout@v3
 
       - uses: actions/setup-python@v4
         with:
           python-version: '3.10'
 
-      - name: Install flake8
-        run: pip install flake8
+      - name: Install mock_pipeline test requirements
+        run: pip install -r mock_pipeline_requirements.txt
 
-      - name: Run flake8
-        run: flake8 dags/
+      - name: Run dbt
+        run : dbt run --target mock_pipeline
 
-  integrity_test:
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v3
-
-      - uses: actions/setup-python@v4
-        with:
-          python-version: '3.10'
-
-      - name: Install integrity test requirements
-        run: pip install -r integrity_tests/requirements.txt
-
-      - name: Initialize Airflow DB
-        run: airflow db init
+      - name: Run dbt tests
+        run : dbt test --target mock_pipeline
 
-      - name: Run integrity tests
-        run: coverage run -m pytest integrity_tests/*
diff --git a/dags/dbt/profiles.yml b/dags/dbt/profiles.yml
@@ -11,3 +11,14 @@ transactions:
         "spark.sql.warehouse.dir": "/opt/airflow/spark-warehouse"
         "spark.sql.parquet.compression.codec": "gzip"
         "spark.hadoop.javax.jdo.option.ConnectionURL": "jdbc:derby:;databaseName=/opt/airflow/metastore_db;create=true"
+
+    mock_pipeline:
+      type: spark
+      host: localhost
+      method: session
+      schema: bank
+      server_side_parameters:
+        "spark.databricks.delta.schema.autoMerge.enabled": "True"
+        "spark.sql.warehouse.dir": "/opt/airflow/spark-warehouse"
+        "spark.sql.parquet.compression.codec": "gzip"
+        "spark.hadoop.javax.jdo.option.ConnectionURL": "jdbc:derby:;databaseName=/opt/airflow/metastore_db;create=true"
diff --git a/mock_pipeline_requirements.txt b/mock_pipeline_requirements.txt
@@ -0,0 +1,3 @@
+dbt-spark[PyHive]==1.7.0b1
+dbt-core==1.7.0b1
+pyspark==3.4.0