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 2, 2024
1 parent e9f1ea9 commit ae6b9f7
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 @@ -124,7 +124,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 @@ -139,17 +139,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 ae6b9f7

Please sign in to comment.