diff --git a/dags/preprocess_actors.py b/dags/preprocess_actors.py index f7d0433..500ccc0 100644 --- a/dags/preprocess_actors.py +++ b/dags/preprocess_actors.py @@ -5,14 +5,13 @@ from airflow.providers.postgres.hooks.postgres import PostgresHook from utils.utils import load_table, normalize_nom, normalize_url, normalize_email, normalize_phone_number, \ - apply_normalization, save_to_database def normalize_data(): # Setup the PostgresHook connection - pg_hook = PostgresHook(postgres_conn_id='your_connection_id') + pg_hook = PostgresHook(postgres_conn_id='lvao-preprod') # Use the hook to get the engine engine = pg_hook.get_sqlalchemy_engine()