test

lyft · May 3, 2024 · 7042b36 · 7042b36
1 parent 6229197
commit 7042b36
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/server/neptune/adhoc/server.go b/server/neptune/adhoc/server.go
@@ -82,13 +82,7 @@ func NewServer(config *adhocconfig.Config) (*Server, error) {
 		"mode": "adhoc",
 	})
 
-	jobStore, err := job.NewStorageBackendStore(config.JobConfig, scope.SubScope("job.store"), config.CtxLogger)
-	if err != nil {
-		return nil, errors.Wrapf(err, "initializing job store")
-	}
-	receiverRegistry := job.NewReceiverRegistry()
-
-	jobStreamHandler := job.NewStreamHandler(jobStore, receiverRegistry, config.TerraformCfg.LogFilters, config.CtxLogger)
+	noopJobStreamHandler := &job.NoopStreamHandler{}
 
 	opts := &temporal.Options{
 		StatsReporter: statsReporter,
@@ -124,7 +118,7 @@ func NewServer(config *adhocconfig.Config) (*Server, error) {
 		config.ServerCfg.URL,
 		config.TemporalCfg.TerraformTaskQueue,
 		config.GithubCfg.TemporalAppInstallationID,
-		jobStreamHandler,
+		noopJobStreamHandler,
 	)
 	if err != nil {
 		return nil, errors.Wrap(err, "initializing terraform activities")