Mercurial > gemma

comparison pkg/imports/queue.go @ 4748:47922c1a088d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Added a 'changed' column to the import.imports table. Changed is update each time the state changes (TODO: solve this with a trigger). The update script takes as approximation the time of the last log entry connected with the particular import.
author Sascha L. Teichmann <sascha.teichmann@intevation.de>
date Fri, 18 Oct 2019 15:34:34 +0200
parents 91cb4a7b1b13
children d727641911a5
comparison
equal deleted inserted replaced
4747:b1428b44e43f 4748:47922c1a088d
136 136
137 const ( 137 const (
138 queueUser = "sys_admin" 138 queueUser = "sys_admin"
139 139
140 reEnqueueRunningSQL = ` 140 reEnqueueRunningSQL = `
141 UPDATE import.imports SET state = 'queued'::import_state 141 UPDATE import.imports SET
142 state = 'queued'::import_state,
143 changed = CURRENT_TIMESTAMP
142 WHERE state = 'running'::import_state` 144 WHERE state = 'running'::import_state`
143 145
144 insertJobSQL = ` 146 insertJobSQL = `
145 INSERT INTO import.imports ( 147 INSERT INTO import.imports (
146 kind, 148 kind,
178 WHERE state = 'queued'::import_state AND 180 WHERE state = 'queued'::import_state AND
179 kind = ANY($1)) 181 kind = ANY($1))
180 LIMIT 1` 182 LIMIT 1`
181 183
182 updateStateSQL = ` 184 updateStateSQL = `
183 UPDATE import.imports SET state = $1::import_state 185 UPDATE import.imports SET
186 state = $1::import_state,
187 changed = CURRENT_TIMESTAMP
184 WHERE id = $2` 188 WHERE id = $2`
185 189
186 updateStateSummarySQL = ` 190 updateStateSummarySQL = `
187 UPDATE import.imports SET 191 UPDATE import.imports SET
188 state = $1::import_state, 192 state = $1::import_state,
193 changed = CURRENT_TIMESTAMP,
189 summary = $2 194 summary = $2
190 WHERE id = $3` 195 WHERE id = $3`
191 196
192 logMessageSQL = ` 197 logMessageSQL = `
193 INSERT INTO import.import_logs ( 198 INSERT INTO import.import_logs (