summaryrefslogtreecommitdiff
path: root/cmd/rescribe/main.go
diff options
context:
space:
mode:
authorNick White <git@njw.name>2022-01-31 14:20:48 +0000
committerNick White <git@njw.name>2022-01-31 14:20:48 +0000
commite837154369ee72c8599b76c9deb879c47e2d4b39 (patch)
tree3caaa1d1968d599fc4ce75370de6604ca7599730 /cmd/rescribe/main.go
parent2fcd0f033f99a05850b4e2f88104bb7e757aeb6c (diff)
rescribe: Ensure status isnt overwritten after an abort, when wipe-only preprocessing
Diffstat (limited to 'cmd/rescribe/main.go')
-rw-r--r--cmd/rescribe/main.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/cmd/rescribe/main.go b/cmd/rescribe/main.go
index cd242af..d4acfc1 100644
--- a/cmd/rescribe/main.go
+++ b/cmd/rescribe/main.go
@@ -662,11 +662,11 @@ func processbook(ctx context.Context, training string, tesscmd string, conn Pipe
conn.Log("Message received on wipeonly queue, processing", msg.Body)
fmt.Printf(" Preprocessing book (wiping only)\n")
err = pipeline.ProcessBook(ctx, msg, conn, pipeline.Wipe, wipePattern, conn.WipeQueueId(), conn.OCRPageQueueId())
- fmt.Printf(" OCRing pages ") // this is expected to be added to with dots by OCRPage output
resetTimer(stopIfQuiet, quietTime)
if err != nil {
return fmt.Errorf("Error during wipe: %v", err)
}
+ fmt.Printf(" OCRing pages ") // this is expected to be added to with dots by OCRPage output
case <-checkOCRPageQueue:
msg, err := conn.CheckQueue(conn.OCRPageQueueId(), QueueTimeoutSecs)
checkOCRPageQueue = time.After(PauseBetweenChecks)