fix: issue where logs were sending duplicate data.

issue: #91
This commit is contained in:
Andrey Melnikov
2020-03-10 17:07:38 -07:00
parent b4ee7d08ab
commit 29d45015d2

View File

@@ -152,16 +152,12 @@ func (s *WorkflowServer) GetWorkflowExecutionLogs(req *api.GetWorkflowExecutionL
}
le := &v1.LogEntry{}
ticker := time.NewTicker(time.Second)
for {
select {
case le = <-watcher:
case <-ticker.C:
}
le = <-watcher
if le == nil {
break
}
if err := stream.Send(&api.LogEntry{
Timestamp: le.Timestamp.String(),
Content: le.Content,