diff --git a/dags/OSV_with_docs.py b/dags/OSV_with_docs.py
index 7a26ee7..dbbb3ab 100644
--- a/dags/OSV_with_docs.py
+++ b/dags/OSV_with_docs.py
@@ -371,7 +371,7 @@ def poruchitelstva(**kwargs):
         , osv.agreement_date as date_begin
         , osv.redemption_date as date_end
     FROM lizingi_garantii osv
-    LEFT JOIN poruchitelstva p on p.uid_dogovor = osv.id
+    LEFT JOIN poruchitelstva p on p.uid_dogovor = osv.id::text
     WHERE p.uid_dogovor is null
     """)
     df = pd.read_sql(query, engine)