From fb82fdae1697b98e5f599aefa87413537ac522d0 Mon Sep 17 00:00:00 2001 From: Nick Sweeting Date: Sun, 17 Nov 2024 20:09:38 -0800 Subject: [PATCH] make actor pending include all obj with retry_at in the past --- archivebox/actors/actor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/archivebox/actors/actor.py b/archivebox/actors/actor.py index 40f47324..9c9db5d9 100644 --- a/archivebox/actors/actor.py +++ b/archivebox/actors/actor.py @@ -315,7 +315,7 @@ class ActorType(Generic[ModelType]): @classproperty def pending_q(cls) -> Q: """Get the filter for objects that are ready for processing.""" - return ~(cls.active_q) & ~(cls.final_q) & ~(cls.future_q) + return (~(cls.active_q) & ~(cls.final_q)) | Q(retry_at__lte=timezone.now()) @classmethod def get_queue(cls, sort: bool=True) -> QuerySet[ModelType]: