Graceful Shutdown Errors

[mgpai22]

I try to stop the pipeline but my program crashes

    if err := i.pipeline.Stop(); err != nil {
        logger.Errorf("failed to stop pipeline: %s", err)
        os.Exit(1)
    }

panic: close of closed channel

goroutine 240 [running]:
github.com/blinklabs-io/adder/pipeline.(*Pipeline).Stop(0xc00049eaf0)
        go/pkg/mod/github.com/blinklabs-io/adder@v0.25.1/pipeline/pipeline.go:110 +0x25

my use case is that I detect something is out of sync. So I want to restart the indexer instance to start back from an old intercept point.

[wolf31o2]

This may be related to #45