Skip to content

Commit 192c045

Browse files
committed
[DOP-31810] Update airflow seed script
1 parent c93b306 commit 192c045

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

data_rentgen/db/scripts/seed/airflow.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,8 @@ def generate_airflow_run(dag_id: str, task_id: str, created_at: datetime, ended_
5959
persistent_log_url=dag_ui,
6060
status=RunStatusDTO.SUCCEEDED,
6161
start_reason=RunStartReasonDTO.AUTOMATIC,
62+
nominal_start_time=created_at.replace(minute=(created_at.minute // 5) * 5, second=0, microsecond=0),
63+
nominal_end_time=ended_at.replace(minute=0, second=0, microsecond=0) + timedelta(hours=1),
6264
)
6365

6466
task_job = JobDTO(

0 commit comments

Comments
 (0)