@@ -19,6 +19,7 @@ package devtronApps
19
19
import (
20
20
"bufio"
21
21
"context"
22
+ "github.com/devtron-labs/common-lib/async"
22
23
"os"
23
24
"time"
24
25
@@ -168,6 +169,7 @@ type HandlerServiceImpl struct {
168
169
workflowService executor.WorkflowService
169
170
blobConfigStorageService pipeline.BlobStorageConfigService
170
171
deploymentEventHandler app.DeploymentEventHandler
172
+ asyncRunnable * async.Runnable
171
173
}
172
174
173
175
func NewHandlerServiceImpl (logger * zap.SugaredLogger ,
@@ -229,7 +231,8 @@ func NewHandlerServiceImpl(logger *zap.SugaredLogger,
229
231
ciLogService pipeline.CiLogService ,
230
232
workflowService executor.WorkflowService ,
231
233
blobConfigStorageService pipeline.BlobStorageConfigService ,
232
- deploymentEventHandler app.DeploymentEventHandler ) (* HandlerServiceImpl , error ) {
234
+ deploymentEventHandler app.DeploymentEventHandler ,
235
+ asyncRunnable * async.Runnable ) (* HandlerServiceImpl , error ) {
233
236
impl := & HandlerServiceImpl {
234
237
logger : logger ,
235
238
cdWorkflowCommonService : cdWorkflowCommonService ,
@@ -296,6 +299,7 @@ func NewHandlerServiceImpl(logger *zap.SugaredLogger,
296
299
workflowService : workflowService ,
297
300
blobConfigStorageService : blobConfigStorageService ,
298
301
deploymentEventHandler : deploymentEventHandler ,
302
+ asyncRunnable : asyncRunnable ,
299
303
}
300
304
config , err := types .GetCdConfig ()
301
305
if err != nil {
0 commit comments