From 204892f54c651801d8fcc73bba492fb06fc50e97 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleksandar=20Vla=C5=A1kali=C4=87?= Date: Fri, 8 Jul 2016 15:56:18 +0200 Subject: [PATCH] Update schedule.py Time adjustment needs to be done when the current hour is greater then passed in hour. (Currently it is the other way around) Is this even needed because of the "Backfill Tasks" capabilities? --- dataduct/pipeline/schedule.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dataduct/pipeline/schedule.py b/dataduct/pipeline/schedule.py index 4909efa..021c562 100644 --- a/dataduct/pipeline/schedule.py +++ b/dataduct/pipeline/schedule.py @@ -88,7 +88,7 @@ def __init__(self, start_time = current_time.replace(minute=load_minutes) start_time = start_time.replace(hour=load_hour, second=0) - if current_time.hour < load_hour: + if current_time.hour > load_hour: if frequency == 'one-time': time_delta -= timedelta(days=1) else: