diff --git a/pkg/service/egress.go b/pkg/service/egress.go index a05444077..29ce6f07a 100644 --- a/pkg/service/egress.go +++ b/pkg/service/egress.go @@ -255,12 +255,6 @@ func (s *EgressService) UpdateStream(ctx context.Context, req *livekit.UpdateStr } } - go func() { - if err := s.es.UpdateEgress(ctx, info); err != nil { - logger.Errorw("could not write egress info", err) - } - }() - return info, nil }