remove jobstream handler

lyft · Apr 22, 2024 · 534e333 · 534e333
1 parent 6babeda
commit 534e333
Showing 1 changed file with 1 addition and 10 deletions.
diff --git a/server/neptune/adhoc/server.go b/server/neptune/adhoc/server.go
@@ -35,7 +35,6 @@ import (
 	internalSync "github.com/runatlantis/atlantis/server/neptune/sync"
 	"github.com/runatlantis/atlantis/server/neptune/temporal"
 	neptune "github.com/runatlantis/atlantis/server/neptune/temporalworker/config"
-	"github.com/runatlantis/atlantis/server/neptune/temporalworker/job"
 	"github.com/runatlantis/atlantis/server/neptune/workflows"
 	"github.com/runatlantis/atlantis/server/neptune/workflows/activities"
 	"github.com/runatlantis/atlantis/server/static"
@@ -82,14 +81,6 @@ 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)
-
 	opts := &temporal.Options{
 		StatsReporter: statsReporter,
 	}
@@ -124,7 +115,7 @@ func NewServer(config *adhocconfig.Config) (*Server, error) {
 		config.ServerCfg.URL,
 		config.TemporalCfg.TerraformTaskQueue,
 		config.GithubCfg.TemporalAppInstallationID,
-		jobStreamHandler,
+		nil,
 	)
 	if err != nil {
 		return nil, errors.Wrap(err, "initializing terraform activities")