File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -1168,7 +1168,7 @@ where
11681168        self . conn ( ) 
11691169            . execute ( 
11701170                "update collector_progress set start_time = statement_timestamp() \  
1171-                  where aid = $1 and step = $2 and end_time is null;", 
1171+                  where aid = $1 and step = $2 and start_time is null and  end_time is null;", 
11721172                & [ & ( aid. 0  as  i32 ) ,  & step] , 
11731173            ) 
11741174            . await 
Original file line number Diff line number Diff line change @@ -1054,7 +1054,7 @@ impl Connection for SqliteConnection {
10541054        self . raw_ref ( ) 
10551055            . execute ( 
10561056                "update collector_progress set start = strftime('%s','now') \  
1057-                  where aid = ? and step = ? and end is null;", 
1057+                  where aid = ? and step = ? and start is null and  end is null;", 
10581058                params ! [ & aid. 0 ,  & step] , 
10591059            ) 
10601060            . unwrap ( ) 
    
 
   
 
     
   
   
          
     
  
    
     
 
    
      
     
 
     
    You can’t perform that action at this time.
  
 
    
  
     
    
      
        
     
 
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments