aboutsummaryrefslogtreecommitdiff
path: root/setup
diff options
context:
space:
mode:
authorTill <2353100+S7evinK@users.noreply.github.com>2023-01-23 13:17:15 +0100
committerGitHub <noreply@github.com>2023-01-23 13:17:15 +0100
commit48fa869fa3578741d1d5775d30f24f6b097ab995 (patch)
treeadaf9b174493a30fec8aeb26cea18f7b42ac9db1 /setup
parent430932f0f161dd836c98082ff97b57beedec02e6 (diff)
Use `t.TempDir` for SQLite databases, so tests don't rip out each others databases (#2950)
This should hopefully finally fix issues about `disk I/O error` as seen [here](https://gitlab.alpinelinux.org/alpine/aports/-/jobs/955030/raw) Hopefully this will also fix `SSL accept attempt failed` issues by disabling HTTP keep alives when generating a config for CI.
Diffstat (limited to 'setup')
-rw-r--r--setup/jetstream/helpers.go5
1 files changed, 5 insertions, 0 deletions
diff --git a/setup/jetstream/helpers.go b/setup/jetstream/helpers.go
index c1ce9583..53365216 100644
--- a/setup/jetstream/helpers.go
+++ b/setup/jetstream/helpers.go
@@ -77,6 +77,11 @@ func JetStreamConsumer(
// The consumer was deleted so stop.
return
} else {
+ // Unfortunately, there's no ErrServerShutdown or similar, so we need to compare the string
+ if err.Error() == "nats: Server Shutdown" {
+ logrus.WithContext(ctx).Warn("nats server shutting down")
+ return
+ }
// Something else went wrong, so we'll panic.
sentry.CaptureException(err)
logrus.WithContext(ctx).WithField("subject", subj).Fatal(err)