[ARVADOS] updated: 1.3.0-1719-gc8919a8e3

Git user git at public.curoverse.com
Tue Oct 22 15:42:39 UTC 2019


Summary of changes:
 services/crunch-run/copier.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

       via  c8919a8e3a27406d707b4491b5858a34525bdeba (commit)
      from  97e783760423f6f0200b057629aa9cd593a5c9c7 (commit)

Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.


commit c8919a8e3a27406d707b4491b5858a34525bdeba
Author: Tom Clegg <tclegg at veritasgenetics.com>
Date:   Tue Oct 22 11:41:51 2019 -0400

    15652: Use BLOCKSIZE const.
    
    Arvados-DCO-1.1-Signed-off-by: Tom Clegg <tclegg at veritasgenetics.com>

diff --git a/services/crunch-run/copier.go b/services/crunch-run/copier.go
index 317db1a7f..f6a64a621 100644
--- a/services/crunch-run/copier.go
+++ b/services/crunch-run/copier.go
@@ -15,6 +15,7 @@ import (
 	"strings"
 
 	"git.curoverse.com/arvados.git/sdk/go/arvados"
+	"git.curoverse.com/arvados.git/sdk/go/keepclient"
 	"git.curoverse.com/arvados.git/sdk/go/manifest"
 )
 
@@ -90,7 +91,7 @@ func (cp *copier) Copy() (string, error) {
 		// full-size blocks, but leave the last short block
 		// open so f's data can be packed with it).
 		dir, _ := filepath.Split(f.dst)
-		if dir != lastparentdir || unflushed > 1<<26 {
+		if dir != lastparentdir || unflushed > keepclient.BLOCKSIZE {
 			if err := fs.Flush("/"+lastparentdir, dir != lastparentdir); err != nil {
 				return "", fmt.Errorf("error flushing output collection file data: %v", err)
 			}

-----------------------------------------------------------------------


hooks/post-receive
-- 




More information about the arvados-commits mailing list