Break backfill loop on `end_dt < start_dt`
parent
8369f557c7
commit
ad37cfbe2f
|
@ -418,6 +418,12 @@ async def start_backfill(
|
||||||
|
|
||||||
start_dt = from_timestamp(start)
|
start_dt = from_timestamp(start)
|
||||||
end_dt = from_timestamp(end)
|
end_dt = from_timestamp(end)
|
||||||
|
|
||||||
|
# if we get a baddly ordered timestamp
|
||||||
|
# pair, imeeditately stop backfilling.
|
||||||
|
if end_dt < start_dt:
|
||||||
|
break
|
||||||
|
|
||||||
(
|
(
|
||||||
array,
|
array,
|
||||||
next_start_dt,
|
next_start_dt,
|
||||||
|
|
Loading…
Reference in New Issue