diff --git a/rpc/egress_client.go b/rpc/egress_client.go index 1ba52cd5..5612df10 100644 --- a/rpc/egress_client.go +++ b/rpc/egress_client.go @@ -44,7 +44,7 @@ func NewEgressClient(nodeID livekit.NodeID, bus psrpc.MessageBus) (EgressClient, clientID := string(nodeID) internalClient, err := NewEgressInternalClient(clientID, bus, middleware.WithRPCRetries(middleware.RetryOptions{ MaxAttempts: retries, - Timeout: psrpc.DefaultClientTimeout, + Timeout: time.Second * 10, IsRecoverable: func(err error) bool { var e psrpc.Error if !errors.As(err, &e) {