diff --git a/pkg/repository/events_s2.go b/pkg/repository/events_s2.go index 1589fbe..1b3536b 100644 --- a/pkg/repository/events_s2.go +++ b/pkg/repository/events_s2.go @@ -60,6 +60,8 @@ type scopedS2EventTarget struct { // fanout continually opens new TLS connections instead of reusing them. func newS2EventClient(token string) *s2.Client { return s2.New(token, &s2.ClientOptions{ + BaseURL: s2.LoadConfigFromEnv().BaseURL, // Klio: a self-hosted S2. See deploy/gcp/beta9-patches. + MakeBasinBaseURL: s2.LoadConfigFromEnv().MakeBasinBaseURL, // Klio: as above. HTTPClient: &http.Client{Transport: http.DefaultTransport, Timeout: s2EventWriteTimeout}, RequestTimeout: s2EventWriteTimeout, RetryConfig: &s2.RetryConfig{