Ошибка планирования воздушного потока: один день пропускается для обработки файла. ⇐ Python

[Anonymous]

Я запланировал свой DAG, и он запускается каждый день в 1 час ночи, но для входного файла он пропускает файл одного дня вместо того, чтобы принимать входной файл с 15 датами. Обрабатывается файл с 14 датами

Код: Выделить всё

default_args = {
'owner': 'abc',
'depends_on_past': False,
'email': ['abc@gmail.com'],
'start_date': datetime.strptime("2024-07-09T12:20:00", "%Y-%m-%dT%H:%M:%S").replace(tzinfo=timezone.utc) - timedelta(hours=5,minutes=30),
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(minutes=5)
}

dag = DAG(
'xyz',
default_args=default_args,
description='INCREMNTAL LOAD DAG',
schedule_interval='30 19 * * *',
)

если кто-нибудь знает, как это решить???

Подробнее здесь: https://stackoverflow.com/questions/787 ... ssing-file