def _next_datetime_with_utc_hour(table_name, utc_hour):
 today = datetime.date.today()
 start_date_time = datetime.datetime(year=today.year, month=today.month, day=today.day, hour=utc_hour, minute=_get_deterministic_value_for_table_name(table_name, 60), second=_get_deterministic_value_for_table_name(table_name, 60))
 if (start_date_time < datetime.datetime.utcnow()):
  one_day = datetime.timedelta(days=1)
  start_date_time += one_day
 return start_date_time

def _next_datetime_with_utc_hour ( table_name , utc_hour ) : today = datetime . date . today ( ) start_date_time = datetime . datetime ( year = today . year , month = today . month , day = today . day , hour = utc_hour , minute = _get_deterministic_value_for_table_name ( table_name , 60 ) , second = _get_deterministic_value_for_table_name ( table_name , 60 ) ) if ( start_date_time < datetime . datetime . utcnow ( ) ) : one_day = datetime . timedelta ( days = 1 ) start_date_time += one_day return start_date_time
datapipeline api is throttling us .