in parquet_flask/io_logic/parquet_query_condition_management_v3.py [0:0]
def __check_time_range(self):
if self.__query_props.min_datetime is None and self.__query_props.max_datetime is None:
self.__is_extending_base = False
return None
min_time = max_time = None
if self.__query_props.min_datetime is not None:
LOGGER.debug(f'setting datetime min condition as sql: {self.__query_props.min_datetime}')
min_time = TimeUtils.get_datetime_obj(self.__query_props.min_datetime)
# conditions.append(f"{CDMSConstants.year_col} >= {min_year}")
self.__conditions.append(f"{CDMSConstants.time_obj_col} >= '{self.__query_props.min_datetime}'")
if self.__query_props.max_datetime is not None:
LOGGER.debug(f'setting datetime max condition as sql: {self.__query_props.max_datetime}')
max_time = TimeUtils.get_datetime_obj(self.__query_props.max_datetime)
# conditions.append(f"{CDMSConstants.year_col} <= {max_year}")
self.__conditions.append(f"{CDMSConstants.time_obj_col} <= '{self.__query_props.max_datetime}'")
if self.__is_extending_base is False:
self.__is_extending_base = False
# TODO add year and month to the conditions, but not sure it will have any effect
return
if min_time is None or max_time is None:
self.__is_extending_base = False
# TODO add year and month to the query conditions. But not sure it will have any effect
return
if min_time > max_time:
# TODO should we throw an error here?
raise ValueError(f'invalid time range')
self.__generate_time_partition_list(min_time, max_time)
return