File tree Expand file tree Collapse file tree 2 files changed +8
-8
lines changed Expand file tree Collapse file tree 2 files changed +8
-8
lines changed Original file line number Diff line number Diff line change 6
6
class Migration (migrations .Migration ):
7
7
8
8
dependencies = [
9
- (' django_dbq' , ' 0004_auto_20210818_0247' ),
9
+ (" django_dbq" , " 0004_auto_20210818_0247" ),
10
10
]
11
11
12
12
operations = [
13
13
migrations .AddField (
14
- model_name = ' job' ,
15
- name = ' run_after' ,
14
+ model_name = " job" ,
15
+ name = " run_after" ,
16
16
field = models .DateTimeField (db_index = True , null = True ),
17
17
),
18
18
]
Original file line number Diff line number Diff line change @@ -68,11 +68,11 @@ def delete_old(self):
68
68
69
69
def to_process (self , queue_name ):
70
70
return self .select_for_update ().filter (
71
- models .Q (queue_name = queue_name ) &
72
- models .Q (state__in = (Job .STATES .READY , Job .STATES .NEW )) &
73
- models .Q (
74
- models .Q (run_after__isnull = True ) |
75
- models .Q (run_after__lte = timezone .now ())
71
+ models .Q (queue_name = queue_name )
72
+ & models .Q (state__in = (Job .STATES .READY , Job .STATES .NEW ))
73
+ & models .Q (
74
+ models .Q (run_after__isnull = True )
75
+ | models .Q (run_after__lte = timezone .now ())
76
76
)
77
77
)
78
78
You can’t perform that action at this time.
0 commit comments