Сельдерей: стандартный метод запроса ожидающих задач?

Есть ли какой-либо стандартный / независимый от серверной части метод для запроса ожидающих задач на основе определенных полей?

Например, у меня есть задача, которую нужно запустить один раз после «последнего взаимодействия с пользователем», и я хотел бы реализовать ее примерно так:

def user_changed_content():
    task = find_task(name="handle_content_change")
    if task is None:
        task = queue_task("handle_content_change")
    task.set_eta(datetime.now() + timedelta(minutes=5))
    task.save()

Или проще подключиться непосредственно к бэкэнду хранилища?