diff --git a/scripts/bigquery_cleaned_layer.py b/scripts/bigquery_cleaned_layer.py index 5a1fe5f..0d112fc 100644 --- a/scripts/bigquery_cleaned_layer.py +++ b/scripts/bigquery_cleaned_layer.py @@ -21,13 +21,13 @@ import logging from typing import Dict import json -from bigquery_config import get_bigquery_client, CONFIG, get_table_id -from bigquery_helpers import ( +from scripts.bigquery_config import get_bigquery_client, CONFIG, get_table_id +from scripts.bigquery_helpers import ( log_update, load_to_bigquery, read_from_bigquery, setup_logging, - save_etl_metadata + save_etl_metadata, ) from google.cloud import bigquery @@ -545,7 +545,7 @@ def run_cleaned_integration(): Dipanggil oleh DAG setelah task staging_integration_to_silver selesai. """ - from bigquery_config import get_bigquery_client + from scripts.bigquery_config import get_bigquery_client client = get_bigquery_client() df_staging = load_staging_data(client) loader = CleanedDataLoader(client, load_mode='full_refresh')