File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -29,7 +29,7 @@ def job_queue_latency(*queues)
2929 query = query . where ( queue_name : queues ) if queues . any?
3030 query = query . where ( performed_at : nil )
3131 query = query . where . not ( error_event : discarded_enum ) . or ( query . where ( error_event : nil ) ) if error_event_supported?
32- query = query . where ( scheduled_at : .. Time . now ) . or ( query . where ( scheduled_at : nil ) )
32+ query = query . where ( " scheduled_at <= ?" , Time . now ) . or ( query . where ( scheduled_at : nil ) )
3333 query = query . order ( scheduled_at : :asc , created_at : :asc )
3434
3535 if ( job = query . first )
@@ -57,7 +57,7 @@ def job_queue_size(*queues)
5757 query = query . where ( queue_name : queues ) if queues . any?
5858 query = query . where ( performed_at : nil )
5959 query = query . where . not ( error_event : discarded_enum ) . or ( query . where ( error_event : nil ) ) if error_event_supported?
60- query = query . where ( scheduled_at : .. Time . now ) . or ( query . where ( scheduled_at : nil ) )
60+ query = query . where ( " scheduled_at <= ?" , Time . now ) . or ( query . where ( scheduled_at : nil ) )
6161 query . count
6262 end
6363 end
You can’t perform that action at this time.
0 commit comments