support multiple controllers

block · Apr 4, 2024 · 9ade2a3 · 9ade2a3
1 parent 911c746
commit 9ade2a3
Show file tree

Hide file tree

Showing 5 changed files with 296 additions and 88 deletions.
diff --git a/backend/controller/controller.go b/backend/controller/controller.go
@@ -172,7 +172,7 @@ func New(ctx context.Context, db *dal.DAL, config Config, runnerScaling scaling.
 		increaseReplicaFailures: map[string]int{},
 	}
 
-	cronSvc := cronjobs.New(ctx, cronjobs.Config{Timeout: config.CronJobTimeout}, db, svc.tasks, svc)
+	cronSvc := cronjobs.New(ctx, key, cronjobs.Config{Timeout: config.CronJobTimeout}, db, svc.tasks, svc)
 	svc.cronJobs = cronSvc
 
 	svc.tasks.Parallel(backoff.Backoff{Min: time.Second, Max: time.Second * 5}, svc.syncRoutes)
@@ -708,7 +708,7 @@ func (s *Service) CreateDeployment(ctx context.Context, req *connect.Request[ftl
 		return nil, fmt.Errorf("%s: %w", "could not create deployment", err)
 	}
 
-	_ = s.cronJobs.CreatedDeployment(ctx, dname, module)
+	s.cronJobs.CreatedDeployment(ctx, dname, module)
 
 	deploymentLogger := s.getDeploymentLogger(ctx, dname)
 	deploymentLogger.Debugf("Created deployment %s", dname)