X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/e663d52fd17d989ad4be1a34413c21537cbe957e..05bf879dfb195871e67eedecba6f654943c39250:/services/crunch-run/upload.go diff --git a/services/crunch-run/upload.go b/services/crunch-run/upload.go index 95925e57c6..ddad8bf475 100644 --- a/services/crunch-run/upload.go +++ b/services/crunch-run/upload.go @@ -18,14 +18,15 @@ import ( "crypto/md5" "errors" "fmt" - "git.curoverse.com/arvados.git/sdk/go/keepclient" - "git.curoverse.com/arvados.git/sdk/go/manifest" "io" "log" "os" "path/filepath" "strings" "sync" + + "git.curoverse.com/arvados.git/sdk/go/keepclient" + "git.curoverse.com/arvados.git/sdk/go/manifest" ) // Block is a data block in a manifest stream @@ -190,6 +191,7 @@ func (m *CollectionWriter) Finish() error { } if stream.Block != nil { stream.uploader <- stream.Block + stream.Block = nil } close(stream.uploader) stream.uploader = nil