noop job stream handler for adhoc flow

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")

server/neptune/temporalworker/job/noop_stream_handler.go

@@ -0,0 +1,38 @@
+package job
+
+import (
+	"context"
+	"sync"
+)
+
+type NoopStreamHandler struct {
+	wg sync.WaitGroup
+}
+
+func (n *NoopStreamHandler) RegisterJob(id string) chan string {
+	jobOutput := make(chan string)
+	n.wg.Add(1)
+	go func() {
+		defer n.wg.Done()
+		for line := range jobOutput {
+			n.handle(&OutputLine{
+				JobID: id,
+				Line:  line,
+			})
+		}
+	}()
+
+	return jobOutput
+}
+
+func (n *NoopStreamHandler) CloseJob(ctx context.Context, jobID string) error {
+	return nil
+}
+
+func (n *NoopStreamHandler) CleanUp(ctx context.Context) error {
+	n.wg.Wait()
+	return nil
+}
+
+func (s *NoopStreamHandler) handle(_ *OutputLine) {
+}