diff options
author | 2023-09-04 20:51:32 +0100 | |
---|---|---|
committer | 2023-09-04 20:51:32 +0100 | |
commit | 31b5c3e11139434c0de4678d35dba5aa0adeb4d0 (patch) | |
tree | fa543863087f00cddbf673a1988b0f75365dfe4c /create_metricity_db.py | |
parent | Swap database creation script to asyncpg (diff) |
Default postgresql driver to asyncpg
Diffstat (limited to 'create_metricity_db.py')
-rw-r--r-- | create_metricity_db.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/create_metricity_db.py b/create_metricity_db.py index a792f8e..1c7acaa 100644 --- a/create_metricity_db.py +++ b/create_metricity_db.py @@ -11,7 +11,7 @@ def parse_db_url(db_url: str) -> SplitResult: """Validate and split the given database url.""" db_url_parts = urlsplit(db_url) if not all(( - db_url_parts.hostname, + db_url_parts.netloc, db_url_parts.username, db_url_parts.password, )): @@ -23,7 +23,7 @@ async def create_db() -> None: parts = parse_db_url(build_db_uri()) try: await asyncpg.connect( - host=parts.hostname, + host=parts.netloc, user=parts.username, database=parts.path[1:], password=parts.password, @@ -33,7 +33,7 @@ async def create_db() -> None: sys_conn = await asyncpg.connect( database="template1", user=parts.username, - host=parts.hostname, + host=parts.netloc, password=parts.password, ) |