@@ -19,7 +19,7 @@ type Service struct {
19
19
lineageRepository LineageRepository
20
20
worker Worker
21
21
logger log.Logger
22
- assetConfig Config
22
+ config Config
23
23
cancelFnList []func ()
24
24
25
25
assetOpCounter metric.Int64Counter
@@ -41,7 +41,7 @@ type ServiceDeps struct {
41
41
LineageRepo LineageRepository
42
42
Worker Worker
43
43
Logger log.Logger
44
- AssetConfig Config
44
+ Config Config
45
45
}
46
46
47
47
func NewService (deps ServiceDeps ) (service * Service , cancel func ()) {
@@ -57,7 +57,7 @@ func NewService(deps ServiceDeps) (service *Service, cancel func()) {
57
57
lineageRepository : deps .LineageRepo ,
58
58
worker : deps .Worker ,
59
59
logger : deps .Logger ,
60
- assetConfig : deps .AssetConfig ,
60
+ config : deps .Config ,
61
61
cancelFnList : make ([]func (), 0 ),
62
62
63
63
assetOpCounter : assetOpCounter ,
@@ -153,7 +153,7 @@ func (s *Service) DeleteAssets(ctx context.Context, request DeleteAssetsRequest)
153
153
}
154
154
155
155
if ! request .DryRun && total > 0 {
156
- newCtx , cancel := context .WithTimeout (context .Background (), s .assetConfig .DeleteAssetsTimeout )
156
+ newCtx , cancel := context .WithTimeout (context .Background (), s .config .DeleteAssetsTimeout )
157
157
s .cancelFnList = append (s .cancelFnList , cancel )
158
158
go s .executeDeleteAssets (newCtx , deleteSQLExpr )
159
159
}
0 commit comments