Temporarily increase elan ctx timeouts (#256)

* Temporarily increase elan ctx timeouts

* Linting

elan/rpc/client.go

@@ -20,7 +20,7 @@ func New(url string, tls bool, tokenFile string) (Client, error) {
 	if strings.Contains(url, "://") {
 		return &elanClient{
 			s:       createServer(url, 8, 10240, 10*1024*1024),
-			timeout: 1 * time.Minute,
+			timeout: 3 * time.Minute,
 		}, nil
 	}
 	client, err := rexclient.New("mettle", url, tls, tokenFile)

elan/rpc/eclient.go

@@ -2,6 +2,7 @@ package rpc
 
 import (
 	"context"
+	"fmt"
 	"io"
 	"os"
 	"time"
@@ -28,7 +29,11 @@ func (e *elanClient) Healthcheck() error {
 func (e *elanClient) ReadBlob(dg *pb.Digest) ([]byte, error) {
 	ctx, cancel := context.WithTimeout(context.Background(), e.timeout)
 	defer cancel()
-	return e.s.readAllBlob(ctx, "cas", dg)
+	blob, err := e.s.readAllBlob(ctx, "cas", dg)
+	if err != nil {
+		return blob, fmt.Errorf("Error reading blob: %w", err)
+	}
+	return blob, nil
 }
 
 func (e *elanClient) WriteBlob(b []byte) (*pb.Digest, error) {
@@ -47,7 +52,11 @@ func (e *elanClient) WriteBlob(b []byte) (*pb.Digest, error) {
 	if e.s.blobExists(ctx, key) {
 		return dg, nil
 	}
-	return dg, e.s.bucket.WriteAll(ctx, key, b)
+	err := e.s.bucket.WriteAll(ctx, key, b)
+	if err != nil {
+		return dg, fmt.Errorf("Error writing blob: %w", err)
+	}
+	return dg, nil
 }
 
 func (e *elanClient) UpdateActionResult(req *pb.UpdateActionResultRequest) (*pb.ActionResult, error) {