summaryrefslogtreecommitdiff
path: root/bookpipeline
diff options
context:
space:
mode:
Diffstat (limited to 'bookpipeline')
-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),