oops

lyft · May 3, 2024 · dfaf36a · dfaf36a
1 parent 7042b36
commit dfaf36a
Showing 1 changed file with 19 additions and 0 deletions.
diff --git a/server/neptune/temporalworker/job/noop_stream_handler.go b/server/neptune/temporalworker/job/noop_stream_handler.go
@@ -0,0 +1,19 @@
+package job
+
+import (
+	"context"
+)
+
+type NoopStreamHandler struct{}
+
+func (n *NoopStreamHandler) RegisterJob(id string) chan string {
+	return make(chan string)
+}
+
+func (n *NoopStreamHandler) CloseJob(ctx context.Context, jobID string) error {
+	return nil
+}
+
+func (n *NoopStreamHandler) CleanUp(ctx context.Context) error {
+	return nil
+}