diff options
| author | Nick White <git@njw.name> | 2019-10-02 12:45:03 +0100 |
|---|---|---|
| committer | Nick White <git@njw.name> | 2019-10-02 12:45:03 +0100 |
| commit | dc3f330570a45d5c7a22e1e23fc0bb3200a78afa (patch) | |
| tree | ce29d3ea98ade7489e391fd30b9d283d91ab5362 | |
| parent | a837c7ff966016f0f18f84d988bf441024d3ff5a (diff) | |
Add -prebinarised flag to booktopipeline
| -rw-r--r-- | bookpipeline/cmd/booktopipeline/main.go | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/bookpipeline/cmd/booktopipeline/main.go b/bookpipeline/cmd/booktopipeline/main.go index 06bc648..296f2c2 100644 --- a/bookpipeline/cmd/booktopipeline/main.go +++ b/bookpipeline/cmd/booktopipeline/main.go @@ -37,6 +37,7 @@ func (f fileWalk) Walk(path string, info os.FileInfo, err error) error { func main() { verbose := flag.Bool("v", false, "Verbose") + wipeonly := flag.Bool("prebinarised", false, "Prebinarised: only preprocessing will be to wipe") flag.Parse() if flag.NArg() < 1 { @@ -68,7 +69,12 @@ func main() { sqssvc := sqs.New(sess) uploader := s3manager.NewUploader(sess) - qname := "rescribepreprocess" + var qname string + if *wipeonly { + qname = "rescribewipeonly" + } else { + qname = "rescribepreprocess" + } verboselog.Println("Getting Queue URL for", qname) result, err := sqssvc.GetQueueUrl(&sqs.GetQueueUrlInput{ QueueName: aws.String(qname), |