fix: use backslash

tutoraspects/patches/local-docker-compose-jobs-services

@@ -16,10 +16,9 @@ aspects-job:
   volumes:
     - ../../env/plugins/aspects/apps/aspects:/app/aspects
     - ../../env/plugins/aspects/apps/aspects/scripts/:/app/aspects/scripts:ro
-  {% if RUN_SUPERSET or RUN_CLICKHOUSE or RUN_RALPH %}depends_on:{% if RUN_SUPERSET %}
-    - superset{% endif %}{% if RUN_CLICKHOUSE%}
-    - clickhouse{% endif %}{% if RUN_RALPH %}
-    - ralph{% endif %}
+  {% if RUN_CLICKHOUSE %}
+  depends_on:
+    - clickhouse
   {% endif %}
 clickhouse-job:
     image: {{DOCKER_IMAGE_CLICKHOUSE}}

tutoraspects/templates/aspects/apps/aspects/scripts/bootstrap.sh

@@ -32,3 +32,5 @@ fi
 
 echo "Installing dbt dependencies"
 dbt deps
+
+mkdir target

tutoraspects/templates/aspects/apps/aspects/scripts/dbt.sh

@@ -10,19 +10,17 @@ echo "Running ${@:2}"
 
 python3 /app/aspects/scripts/insert_data.py load
 
-dbt compile
-
 # If state exists and we've asked to only run changed files, add the flag
-if [ "$1" == "True" ] && [ -e "${DBT_STATE}manifest.json" ]
+if [ "$1" == "True" ] && [ -e "${DBT_STATE}/manifest.json" ]
 then
-  echo "Found ${DBT_STATE}manifest.json so only running modified items and their downstreams"
+  echo "Found ${DBT_STATE}/manifest.json so only running modified items and their downstreams"
   ${@:2} -s state:modified+
 else
   echo "Running command *without* state:modified+ this may take a long time."
   ${@:2}
 fi
 
-if [ -e "${DBT_STATE}manifest.json" ]
+if [ -e "${DBT_STATE}/manifest.json" ]
 then
   echo "Updating dbt state..."
   python3 /app/aspects/scripts/insert_data.py sink

tutoraspects/templates/aspects/apps/aspects/scripts/insert_data.py

@@ -7,7 +7,7 @@
 DBT_PROJECT_ROOT = "/app/aspects-dbt"
 
 DBT_STATE_DIR = "{{DBT_STATE_DIR}}"
-
+print("Insert data script.")
 client = clickhouse_connect.get_client(
     host="{{CLICKHOUSE_HOST}}",
     username='{{CLICKHOUSE_ADMIN_USER}}',
@@ -16,7 +16,7 @@
 
 def sink_files():
     files = []
-    file_name = f"{DBT_STATE_DIR}manifest.json"
+    file_name = f"{DBT_STATE_DIR}/manifest.json"
 
     with open(file_name, "r") as file:
         content = file.read()
@@ -37,9 +37,11 @@ def sink_files():
 
 def load_files():
     result = client.query("SELECT path, content from {{ ASPECTS_EVENT_SINK_DATABASE }}.aspects_data OPTIMIZE FINAL")
+    if not result.result_rows:
+        print("There is no state stored.")
     for row in result.result_rows:
         path, content = row
-        file_path = f"{DBT_STATE_DIR}manifest.json"
+        file_path = f"{DBT_STATE_DIR}/manifest.json"
         with open(file_path, "w") as f:
             print(f"Loading: {file_path}")
             f.write(content)