in ees_microsoft_outlook/base_command.py [0:0]
def get_datetime_iterable_list(self, start_time, end_time):
"""Get time range partition based on time duration and thread count
:param start_time: Start time for fetching data
:param end_time: End time for fetching data
"""
thread_count = self.config.get_value("source_sync_thread_count")
datelist_mails = split_date_range_into_chunks(
start_time,
end_time,
thread_count,
)
time_range_list = []
for num in range(0, thread_count):
time_range_list.append((datelist_mails[num], datelist_mails[num + 1]))
return time_range_list