diff --git a/src/pkg/repository/repository.go b/src/pkg/repository/repository.go index 2a2ac34ee..272861d31 100644 --- a/src/pkg/repository/repository.go +++ b/src/pkg/repository/repository.go @@ -227,12 +227,9 @@ func ConnectAndSendConnectEvent(ctx context.Context, } r := repo.(*repository) + r.Bus.Event(ctx, events.RepoConnect, nil) - if err == nil { - r.Bus.Event(ctx, events.RepoConnect, nil) - } - - return r, err + return r, nil } func (r *repository) Close(ctx context.Context) error {