@@ -19,6 +19,7 @@ package devtronApps
1919import (
2020 "bufio"
2121 "context"
22+ "github.com/devtron-labs/common-lib/async"
2223 "os"
2324 "time"
2425
@@ -168,6 +169,7 @@ type HandlerServiceImpl struct {
168169 workflowService executor.WorkflowService
169170 blobConfigStorageService pipeline.BlobStorageConfigService
170171 deploymentEventHandler app.DeploymentEventHandler
172+ asyncRunnable * async.Runnable
171173}
172174
173175func NewHandlerServiceImpl (logger * zap.SugaredLogger ,
@@ -229,7 +231,8 @@ func NewHandlerServiceImpl(logger *zap.SugaredLogger,
229231 ciLogService pipeline.CiLogService ,
230232 workflowService executor.WorkflowService ,
231233 blobConfigStorageService pipeline.BlobStorageConfigService ,
232- deploymentEventHandler app.DeploymentEventHandler ) (* HandlerServiceImpl , error ) {
234+ deploymentEventHandler app.DeploymentEventHandler ,
235+ asyncRunnable * async.Runnable ) (* HandlerServiceImpl , error ) {
233236 impl := & HandlerServiceImpl {
234237 logger : logger ,
235238 cdWorkflowCommonService : cdWorkflowCommonService ,
@@ -296,6 +299,7 @@ func NewHandlerServiceImpl(logger *zap.SugaredLogger,
296299 workflowService : workflowService ,
297300 blobConfigStorageService : blobConfigStorageService ,
298301 deploymentEventHandler : deploymentEventHandler ,
302+ asyncRunnable : asyncRunnable ,
299303 }
300304 config , err := types .GetCdConfig ()
301305 if err != nil {
0 commit comments