summaryrefslogtreecommitdiff
path: root/pipelinepreprocess
diff options
context:
space:
mode:
authorNick White <git@njw.name>2019-08-13 16:53:14 +0100
committerNick White <git@njw.name>2019-08-13 16:53:14 +0100
commite9587728ff52846cb43e42531b4c4772e3516f13 (patch)
tree4678fc52a8457c00afef251e1a214458279806d3 /pipelinepreprocess
parent7af5dcfcbbab26c48f210e138667712b1f90288c (diff)
Correct typo in bucket name for pipelinepreprocess; tested and seems to work, remarkably
Diffstat (limited to 'pipelinepreprocess')
-rw-r--r--pipelinepreprocess/main.go3
1 files changed, 2 insertions, 1 deletions
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
}