diff --git a/bridgev2/bridge.go b/bridgev2/bridge.go index bdc8480d..aef86196 100644 --- a/bridgev2/bridge.go +++ b/bridgev2/bridge.go @@ -107,8 +107,8 @@ func (e DBUpgradeError) Unwrap() error { return e.Err } -func (br *Bridge) Start() error { - ctx := br.Log.WithContext(context.Background()) +func (br *Bridge) Start(ctx context.Context) error { + ctx = br.Log.WithContext(ctx) err := br.StartConnectors(ctx) if err != nil { return err