@@ -163,8 +163,8 @@ static MIGRATIONS: &[&str] = &[
163
163
create table collector_progress(
164
164
aid smallint not null references artifact(id) on delete cascade on update cascade,
165
165
step text not null,
166
- start timestamptz,
167
- end timestamptz
166
+ start_time timestamptz,
167
+ end_time timestamptz
168
168
);
169
169
"# ,
170
170
] ;
@@ -783,7 +783,7 @@ where
783
783
async fn collector_start ( & self , aid : ArtifactIdNumber , steps : & [ String ] ) {
784
784
self . conn ( )
785
785
. execute (
786
- "delete from collector_progress where start is null or end is null;" ,
786
+ "delete from collector_progress where start_time is null or end_time is null;" ,
787
787
& [ ] ,
788
788
)
789
789
. await
@@ -802,8 +802,8 @@ where
802
802
async fn collector_start_step ( & self , aid : ArtifactIdNumber , step : & str ) {
803
803
self . conn ( )
804
804
. execute (
805
- "update collector_progress set start = statement_timestamp() \
806
- where aid = $1 and step = $2 and start is null and end is null;",
805
+ "update collector_progress set start_time = statement_timestamp() \
806
+ where aid = $1 and step = $2 and start_time is null and end_time is null;",
807
807
& [ & ( aid. 0 as i16 ) , & step] ,
808
808
)
809
809
. await
@@ -812,8 +812,8 @@ where
812
812
async fn collector_end_step ( & self , aid : ArtifactIdNumber , step : & str ) {
813
813
self . conn ( )
814
814
. execute (
815
- "update collector_progress set end = statement_timestamp() \
816
- where aid = $1 and step = $2 and start is not null and end is null;",
815
+ "update collector_progress set end_time = statement_timestamp() \
816
+ where aid = $1 and step = $2 and start_time is not null and end_time is null;",
817
817
& [ & ( aid. 0 as i16 ) , & step] ,
818
818
)
819
819
. await
0 commit comments