From e9587728ff52846cb43e42531b4c4772e3516f13 Mon Sep 17 00:00:00 2001
From: Nick White <git@njw.name>
Date: Tue, 13 Aug 2019 16:53:14 +0100
Subject: Correct typo in bucket name for pipelinepreprocess; tested and seems
to work, remarkably
---
pipelinepreprocess/main.go | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
(limited to 'pipelinepreprocess')
diff --git a/pipelinepreprocess/main.go b/pipelinepreprocess/main.go
index dd122aa..fd73725 100644
--- a/pipelinepreprocess/main.go
+++ b/pipelinepreprocess/main.go
@@ -54,7 +54,7 @@ func download(dl chan string, pre chan string, downloader *s3manager.Downloader,
_, err = downloader.Download(f,
&s3.GetObjectInput{
- Bucket: aws.String("inprogress"),
+ Bucket: aws.String("rescribeinprogress"),
Key: &key })
if err != nil {
log.Fatalln("Failed to download", key, err)
@@ -176,6 +176,7 @@ func main() {
bookname = *msgResult.Messages[0].Body
verboselog.Println("Message received:", bookname)
} else {
+ verboselog.Println("No message received, sleeping")
time.Sleep(PauseBetweenChecks)
continue
}
--
cgit v1.2.1-24-ge1ad