Фильтр Django «меньше чем» datetime не работает правильно - PullRequest
Новая
       35

Фильтр Django «меньше чем» datetime не работает правильно

1 голос
/ 15 марта 2019

Я пытаюсь отфильтровать набор запросов Django по отметке времени (меньше определенного значения).Однако фильтр, похоже, пропускает записи, которые НЕ меньше указанной метки времени.Вот пример функции: 

def check_jobs_status_3():
    current_time = datetime.utcnow()
    time_threshold = current_time - timedelta(seconds=60)
    print("$$$$$$$$$$$$ current_time = {}, timedelta = {}, time_threshold = {}".format(current_time,timedelta(seconds=60),time_threshold))
    stuck_jobs_qs = Job.objects.filter(last_updated__lt=time_threshold)
    for stuck_job in stuck_jobs_qs:
        print("############################## Job #{} (last_updated = {}) no encoding status after {} seconds. Re-enqueueing.".format(stuck_job.id,stuck_job.last_updated,get_video_encoding_timeout_seconds()))

Вот вывод: 

$$$$$$$$$$$$ current_time = 2019-03-14 20:54:15.221554, timedelta = 0:01:00, time_threshold = 2019-03-14 20:53:15.221554
############################## Job #20 (last_updated = 2019-03-14 20:54:15.221264+00:00) no encoding status after 60 seconds. Re-enqueueing.

Как видите, я получаю запись с last_updated, установленным в 2019-03-14 20:54:15, что НЕ меньше значения фильтра 2019-03-14 20: 53: 15

Вот определение поля last_updated: 

last_updated = models.DateTimeField(auto_now=True)

Что можетпроблема быть?

1 Ответ

1 голос
/ 15 марта 2019

Используйте метод Django с учетом часовых поясов django.utils.timezone.now. 

from django.utils import timezone

# ...

def check_jobs_status_3():
    current_time = timezone.now()  # change this
    time_threshold = current_time - timedelta(seconds=60)
    print("$$$$$$$$$$$$ current_time = {}, timedelta = {}, time_threshold = {}".format(current_time,timedelta(seconds=60),time_threshold))
    stuck_jobs_qs = Job.objects.filter(last_updated__lt=time_threshold)
    for stuck_job in stuck_jobs_qs:
        print("############################## Job #{} (last_updated = {}) no encoding status after {} seconds. Re-enqueueing.".format(stuck_job.id,stuck_job.last_updated,get_video_encoding_timeout_seconds()))
...