diff --git a/dags/OSV.py b/dags/OSV.py index cae8591..97b2771 100644 --- a/dags/OSV.py +++ b/dags/OSV.py @@ -59,7 +59,7 @@ def read_data_1C(**kwargs): conn.execute(f"CREATE TEMP TABLE temp_{table_name} AS SELECT * FROM public.{table_name} WHERE 1 = 0") df.to_sql( f'temp_{table_name}', - con=conn + con=conn, if_exists='append', index=False, method='multi'