diff --git a/dags/decors.py b/dags/decors.py index a02a7c3eefac948f7390c110fdc5169b393205ad..7fedc21ddba137055563ee49e597c2380e037905 100644 --- a/dags/decors.py +++ b/dags/decors.py @@ -33,7 +33,7 @@ def get_connection(conn_id): if conn_id.startswith('vault'): vault_hook = VaultHook(vault_conn_id='my_vault') con = vault_hook.get_secret( - secret_path=f"ssh-credentials/{conn_id[6:]}") + secret_path=f"/data/ssh-credentials/{conn_id[6:]}") print(f"Got some values from vault {list(con.keys())}") # for now SSH is hardcoded