diff --git a/dags/pogasheniya.py b/dags/pogasheniya.py
index 8ff21c4..6958781 100644
--- a/dags/pogasheniya.py
+++ b/dags/pogasheniya.py
@@ -34,7 +34,7 @@ def get_db_engine():
 def pogasheniya(**kwargs):
     engine = get_db_engine()
     query = text("""
-    SELECT
+    SELECT DISTINCT
           osv.schet
         , osv.uid_subkonto2 as uid_dogovor
         , osv.subkonto2 as name