projects
/
lightning.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix coordinates in hgvs annotations.
[lightning.git]
/
merge.go
diff --git
a/merge.go
b/merge.go
index 4198ea88b73d69b99d366320d2a987387a2506f4..68560edbd0ae62af9fd203ba9aa6d2867a1fe883 100644
(file)
--- a/
merge.go
+++ b/
merge.go
@@
-1,4
+1,8
@@
-package main
+// Copyright (C) The Lightning Authors. All rights reserved.
+//
+// SPDX-License-Identifier: AGPL-3.0
+
+package lightning
import (
"bufio"
import (
"bufio"
@@
-70,10
+74,11
@@
func (cmd *merger) RunCommand(prog string, args []string, stdin io.Reader, stdou
Name: "lightning merge",
Client: arvados.NewClientFromEnv(),
ProjectUUID: *projectUUID,
Name: "lightning merge",
Client: arvados.NewClientFromEnv(),
ProjectUUID: *projectUUID,
- RAM:
15
0000000000,
+ RAM:
70
0000000000,
VCPUs: 16,
Priority: *priority,
APIAccess: true,
VCPUs: 16,
Priority: *priority,
APIAccess: true,
+ KeepCache: 1,
}
for i := range cmd.inputs {
err = runner.TranslatePaths(&cmd.inputs[i])
}
for i := range cmd.inputs {
err = runner.TranslatePaths(&cmd.inputs[i])
@@
-172,7
+177,7
@@
func (cmd *merger) doMerge() error {
go func(input string) {
defer wg.Done()
log.Printf("%s: reading", input)
go func(input string) {
defer wg.Done()
log.Printf("%s: reading", input)
- err := cmd.tilelib.LoadGob(ctx, rdr, strings.HasSuffix(input, ".gz")
, nil
)
+ err := cmd.tilelib.LoadGob(ctx, rdr, strings.HasSuffix(input, ".gz"))
if err != nil {
cmd.setError(fmt.Errorf("%s: load failed: %w", input, err))
cancel()
if err != nil {
cmd.setError(fmt.Errorf("%s: load failed: %w", input, err))
cancel()