Merge branch 'fixes/#193' into features/#15-osmtgmod-to-pypsa

openego · Apr 1, 2021 · 527f6f0 · 527f6f0
2 parents aed2808 + 62b0fbc
commit 527f6f0
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/src/egon/data/cli.py b/src/egon/data/cli.py
@@ -331,12 +331,11 @@ def render(template, target, update=True, inserts={}, **more_inserts):
         airflow.query(Connection).filter_by(conn_id="egon_data").one_or_none()
     )
     connection = connection if connection else Connection(conn_id="egon_data")
-    connection.uri = (
-        f'postgresql://{options["--database-user"]}'
-        f':{options["--database-password"]}'
-        f'@{options["--database-host"]}:{options["--database-port"]}'
-        f'/{options["--database-name"]}'
-    )
+    connection.login = options["--database-user"]
+    connection.password = options["--database-password"]
+    connection.host = options["--database-host"]
+    connection.port = options["--database-port"]
+    connection.schema = options["--database-name"]
     airflow.add(connection)
     airflow.commit()