Mercurial > gemma
changeset 1890:b1b0db195cc5
Put fairway dimension import to staging area.
| author | Raimund Renkert <raimund.renkert@intevation.de> |
|---|---|
| date | Fri, 18 Jan 2019 10:18:21 +0100 |
| parents | b6d0460b069d |
| children | 80d3ac4328fe |
| files | pkg/imports/fd.go |
| diffstat | 1 files changed, 15 insertions(+), 4 deletions(-) [+] |
line wrap: on
line diff
--- a/pkg/imports/fd.go Fri Jan 18 10:04:55 2019 +0100 +++ b/pkg/imports/fd.go Fri Jan 18 10:18:21 2019 +0100 @@ -67,7 +67,7 @@ func (fdJobCreator) Description() string { return "fairway dimension" } -func (fdJobCreator) AutoAccept() bool { return true } +func (fdJobCreator) AutoAccept() bool { return false } func (fdJobCreator) Create(_ JobKind, data string) (Job, error) { fd := new(FairwayDimension) @@ -83,9 +83,13 @@ } } -// StageDone is a NOP for fairway dimensions imports. -func (fdJobCreator) StageDone(context.Context, *sql.Tx, int64) error { - return nil +func (fdJobCreator) StageDone( + ctx context.Context, + tx *sql.Tx, + id int64, +) error { + _, err := tx.ExecContext(ctx, fdStageDoneSQL, id) + return err } // CleanUp for fairway dimension imports is a NOP. @@ -96,6 +100,13 @@ } const ( + fdStageDoneSQL = ` +UPDATE waterway.fairway_dimensions SET staging_done = true +WHERE id = ( + SELECT key from waterway.track_imports + WHERE import_id = $1 AND + relation = 'waterway.fairway_dimensions'::regclass)` + deleteFairwayDimensionSQL = ` WITH resp AS ( SELECT best_utm(area::geometry) AS t,