Skip to content

Commit 734c583

Browse files
committed
add more logs
1 parent 572c381 commit 734c583

File tree

4 files changed

+63
-123
lines changed

4 files changed

+63
-123
lines changed

Dockerfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ WORKDIR /go/src/repo
88
COPY go.mod go.sum ./
99
RUN go mod download && go mod verify
1010
COPY . .
11-
RUN CGO_ENABLED=0 make
11+
RUN CGO_ENABLED=0 GOOS=linux GOARCH=amd64 make
1212

1313
###################### Stage II ######################
1414
FROM ubuntu:24.04

dgraph/cmd/dgraphimport/dgo_test.go

Lines changed: 0 additions & 47 deletions
This file was deleted.

edgraph/server.go

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1829,18 +1829,20 @@ func (s *ServerV25) UpdateExtSnapshotStreamingState(ctx context.Context,
18291829

18301830
groups, err := worker.ProposeDrain(ctx, req)
18311831
if err != nil {
1832+
glog.Errorf("[import] failed to propose drain mode: %v", err)
18321833
return nil, err
18331834
}
18341835

1835-
resp := &apiv2.UpdateExtSnapshotStreamingStateResponse{Groups: groups}
1836-
1837-
return resp, nil
1836+
return &apiv2.UpdateExtSnapshotStreamingStateResponse{Groups: groups}, nil
18381837
}
18391838

18401839
func (s *ServerV25) StreamExtSnapshot(stream apiv2.Dgraph_StreamExtSnapshotServer) error {
18411840
defer x.ExtSnapshotStreamingState(false)
1842-
1843-
return worker.InStream(stream)
1841+
if err := worker.InStream(stream); err != nil {
1842+
glog.Errorf("[import] failed to stream external snapshot: %v", err)
1843+
return err
1844+
}
1845+
return nil
18441846
}
18451847

18461848
// CommitOrAbort commits or aborts a transaction.

0 commit comments

Comments
 (0)