summaryrefslogtreecommitdiff
path: root/bookpipeline/cmd/booktopipeline
diff options
context:
space:
mode:
authorNick White <git@njw.name>2019-10-02 12:45:03 +0100
committerNick White <git@njw.name>2019-10-02 12:45:03 +0100
commitdc3f330570a45d5c7a22e1e23fc0bb3200a78afa (patch)
treece29d3ea98ade7489e391fd30b9d283d91ab5362 /bookpipeline/cmd/booktopipeline
parenta837c7ff966016f0f18f84d988bf441024d3ff5a (diff)
Add -prebinarised flag to booktopipeline
Diffstat (limited to 'bookpipeline/cmd/booktopipeline')
-rw-r--r--bookpipeline/cmd/booktopipeline/main.go8
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),