Skip to content

Commit

Permalink
renamed argument variable
Browse files Browse the repository at this point in the history
  • Loading branch information
share2kanna committed Jun 6, 2024
1 parent 90dbd43 commit 661712e
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions capten/agent/internal/app/app.go
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,7 @@ func configurePostgresDB() error {
func initializeJobScheduler(
cfg *config.SericeConfig,
as *captenstore.Store,
handler *agentapi.Agent,
agentHandler *agentapi.Agent,
) (*job.Scheduler, error) {
s := job.NewScheduler(log)
if cfg.CrossplaneSyncJobEnabled {
Expand All @@ -146,17 +146,17 @@ func initializeJobScheduler(
}

// Add Default plugin deployer job
addDefualtPluginsDeployerJob(s, handler)
addDefualtPluginsDeployerJob(s, agentHandler)

log.Info("successfully initialized job scheduler")
return s, nil
}

func addDefualtPluginsDeployerJob(
s *job.Scheduler,
handler *agentapi.Agent,
agentHandler *agentapi.Agent,
) {
dpd, err := defaultplugindeployer.NewDefaultPluginsDeployer(log, "@every 10m", handler)
dpd, err := defaultplugindeployer.NewDefaultPluginsDeployer(log, "@every 10m", agentHandler)
if err != nil {
log.Fatal("failed to init default plugins deployer job", err)
}
Expand Down

0 comments on commit 661712e

Please sign in to comment.