Skip to content

Commit e922191

Browse files
committed
bbgo: configure persistence facade into the isolation context
1 parent 673304b commit e922191

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

pkg/bbgo/bootstrap.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ func BootstrapEnvironmentLightweight(ctx context.Context, environ *Environment,
1515
}
1616

1717
if userConfig.Persistence != nil {
18-
if err := ConfigurePersistence(userConfig.Persistence); err != nil {
18+
if err := ConfigurePersistence(ctx, userConfig.Persistence); err != nil {
1919
return errors.Wrap(err, "persistence configure error")
2020
}
2121
}
@@ -33,7 +33,7 @@ func BootstrapEnvironment(ctx context.Context, environ *Environment, userConfig
3333
}
3434

3535
if userConfig.Persistence != nil {
36-
if err := ConfigurePersistence(userConfig.Persistence); err != nil {
36+
if err := ConfigurePersistence(ctx, userConfig.Persistence); err != nil {
3737
return errors.Wrap(err, "persistence configure error")
3838
}
3939
}

pkg/bbgo/persistence.go

+4-1
Original file line numberDiff line numberDiff line change
@@ -102,12 +102,15 @@ func NewPersistenceServiceFacade(conf *PersistenceConfig) (*service.PersistenceS
102102
return facade, nil
103103
}
104104

105-
func ConfigurePersistence(conf *PersistenceConfig) error {
105+
func ConfigurePersistence(ctx context.Context, conf *PersistenceConfig) error {
106106
facade, err := NewPersistenceServiceFacade(conf)
107107
if err != nil {
108108
return err
109109
}
110110

111+
isolation := GetIsolationFromContext(ctx)
112+
isolation.persistenceServiceFacade = facade
113+
111114
persistenceServiceFacade = facade
112115
return nil
113116
}

0 commit comments

Comments
 (0)