Index: common/logdog/coordinator/stream.go |
diff --git a/common/logdog/coordinator/stream.go b/common/logdog/coordinator/stream.go |
index 5509128899472518fac22fd61170c1cd926a4252..57a7c770c9e2c42836e8512f44ca6b238e27ad36 100644 |
--- a/common/logdog/coordinator/stream.go |
+++ b/common/logdog/coordinator/stream.go |
@@ -119,6 +119,7 @@ func (s *Stream) Get(ctx context.Context, p *StreamGetParams) ([]*logpb.LogEntry |
} |
req := p.r |
+ req.Project = string(s.c.project) |
req.Path = string(s.path) |
if p.stateP != nil { |
req.State = true |
@@ -139,7 +140,8 @@ func (s *Stream) Get(ctx context.Context, p *StreamGetParams) ([]*logpb.LogEntry |
// variable. |
func (s *Stream) Tail(ctx context.Context, stateP *LogStream) (*logpb.LogEntry, error) { |
req := logdog.TailRequest{ |
- Path: string(s.path), |
+ Project: string(s.c.project), |
+ Path: string(s.path), |
} |
if stateP != nil { |
req.State = true |