diff --git a/site/db/contracts.py b/site/db/contracts.py
index 5654364..53b5f9b 100644
--- a/site/db/contracts.py
+++ b/site/db/contracts.py
@@ -1,5 +1,5 @@
 """Contracts CRUD."""
-from connection import query, execute, execute_returning
+from db.connection import query, execute, execute_returning
 
 
 def insert(number, client=""):
diff --git a/site/db/documents.py b/site/db/documents.py
index 3b5364f..0a11a76 100644
--- a/site/db/documents.py
+++ b/site/db/documents.py
@@ -1,5 +1,5 @@
 """Documents CRUD."""
-from connection import query, execute, execute_returning
+from db.connection import query, execute, execute_returning
 
 
 def insert(filename, mime_type, original_bytes, status="uploaded", batch_id=None, zip_source=None, content_hash=None):
diff --git a/site/db/prompts.py b/site/db/prompts.py
index ffd2413..c90a64c 100644
--- a/site/db/prompts.py
+++ b/site/db/prompts.py
@@ -1,5 +1,5 @@
 """Prompts CRUD."""
-from connection import query, execute, execute_returning
+from db.connection import query, execute, execute_returning
 
 
 def _serialize(row):
diff --git a/site/db/spec_current.py b/site/db/spec_current.py
index f3724dc..ac4dd9c 100644
--- a/site/db/spec_current.py
+++ b/site/db/spec_current.py
@@ -1,5 +1,5 @@
 """spec_current — текущее состояние спецификации."""
-from connection import query
+from db.connection import query
 
 
 def list_by_contract(contract_id):
diff --git a/site/db/spec_events.py b/site/db/spec_events.py
index 585833b..f0f505d 100644
--- a/site/db/spec_events.py
+++ b/site/db/spec_events.py
@@ -1,6 +1,6 @@
 """spec_events — event sourcing: apply ops, reset contract."""
 import json, uuid
-from connection import query, execute, get_pool
+from db.connection import query, execute, get_pool
 
 
 def reset(contract_id):
diff --git a/site/db/supplements.py b/site/db/supplements.py
index 901c836..d6d282e 100644
--- a/site/db/supplements.py
+++ b/site/db/supplements.py
@@ -1,5 +1,5 @@
 """Supplements CRUD."""
-from connection import query, execute, execute_returning
+from db.connection import query, execute, execute_returning
 
 
 def insert(contract_id, document_id, supp_type="additional"):