File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -128,10 +128,10 @@ impl Experiment {
128
128
Ok ( db. exists ( "SELECT rowid FROM experiments WHERE name = ?1;" , & [ & name] ) ?)
129
129
}
130
130
131
- pub fn all ( db : & Database ) -> Fallible < Vec < Experiment > > {
131
+ pub fn unfinished ( db : & Database ) -> Fallible < Vec < Experiment > > {
132
132
let records = db. query (
133
- "SELECT * FROM experiments ORDER BY priority DESC, created_at;" ,
134
- & [ ] ,
133
+ "SELECT * FROM experiments WHERE status != ?1 ORDER BY priority DESC, created_at;" ,
134
+ & [ & Status :: Completed . to_str ( ) ] ,
135
135
|r| ExperimentDBRecord :: from_row ( r) ,
136
136
) ?;
137
137
records
Original file line number Diff line number Diff line change @@ -65,7 +65,7 @@ pub fn endpoint_queue(data: Arc<Data>) -> Fallible<Response<Body>> {
65
65
let mut generating_report = Vec :: new ( ) ;
66
66
let mut report_failed = Vec :: new ( ) ;
67
67
68
- for experiment in Experiment :: all ( & data. db ) ? {
68
+ for experiment in Experiment :: unfinished ( & data. db ) ? {
69
69
// Don't include completed experiments in the queue
70
70
if experiment. status == Status :: Completed {
71
71
continue ;
You can’t perform that action at this time.
0 commit comments