diff --git a/dags/OSV.py b/dags/OSV.py index 010d648..31d8cd3 100644 --- a/dags/OSV.py +++ b/dags/OSV.py @@ -63,6 +63,7 @@ def read_data_1C(**kwargs): # Проходим циклом по каждому дню print("\nПрохождение по дням календаря:") for i, date in enumerate(date_range): + print(f'{date}') query = f"""ВЫБРАТЬ ОстаткиОбороты.Счет, ОстаткиОбороты.Субконто1, @@ -226,7 +227,7 @@ def read_data_1C(**kwargs): , uid_subkonto2 , uid_subkonto1 , uid_organizaciya - , CURRENT_DATE::date::timestamp + , get_date::date::timestamp FROM temp_{table_name} ON CONFLICT (schet, uid_subkonto2, uid_subkonto1, uid_organizaciya, get_date) DO UPDATE SET