diff --git a/internal/maintenance/job_rescuer.go b/internal/maintenance/job_rescuer.go
index 7befcddf..6d2dc957 100644
--- a/internal/maintenance/job_rescuer.go
+++ b/internal/maintenance/job_rescuer.go
@@ -274,7 +274,7 @@ func (s *JobRescuer) runOnce(ctx context.Context) (*rescuerRunOnceResult, error)
 }
 
 func (s *JobRescuer) getStuckJobs(ctx context.Context) ([]*rivertype.JobRow, error) {
-	ctx, cancelFunc := context.WithTimeout(ctx, 30*time.Second)
+	ctx, cancelFunc := context.WithTimeout(ctx, riversharedmaintenance.TimeoutDefault)
 	defer cancelFunc()
 
 	stuckHorizon := time.Now().Add(-s.Config.RescueAfter)
diff --git a/internal/maintenance/job_scheduler.go b/internal/maintenance/job_scheduler.go
index 16a6c02c..76d1243d 100644
--- a/internal/maintenance/job_scheduler.go
+++ b/internal/maintenance/job_scheduler.go
@@ -164,7 +164,7 @@ func (s *JobScheduler) runOnce(ctx context.Context) (*schedulerRunOnceResult, er
 	for {
 		// Wrapped in a function so that defers run as expected.
 		numScheduled, err := func() (int, error) {
-			ctx, cancelFunc := context.WithTimeout(ctx, 30*time.Second)
+			ctx, cancelFunc := context.WithTimeout(ctx, riversharedmaintenance.TimeoutDefault)
 			defer cancelFunc()
 
 			tx, err := s.exec.Begin(ctx)
diff --git a/internal/maintenance/queue_cleaner.go b/internal/maintenance/queue_cleaner.go
index 3eef3a1f..3eb1d302 100644
--- a/internal/maintenance/queue_cleaner.go
+++ b/internal/maintenance/queue_cleaner.go
@@ -158,7 +158,7 @@ func (s *QueueCleaner) runOnce(ctx context.Context) (*queueCleanerRunOnceResult,
 	for {
 		// Wrapped in a function so that defers run as expected.
 		queuesDeleted, err := func() ([]string, error) {
-			ctx, cancelFunc := context.WithTimeout(ctx, 30*time.Second)
+			ctx, cancelFunc := context.WithTimeout(ctx, riversharedmaintenance.TimeoutDefault)
 			defer cancelFunc()
 
 			queuesDeleted, err := s.exec.QueueDeleteExpired(ctx, &riverdriver.QueueDeleteExpiredParams{
diff --git a/rivershared/circuitbreaker/circuit_breaker.go b/rivershared/circuitbreaker/circuit_breaker.go
index cc556444..f0e9503a 100644
--- a/rivershared/circuitbreaker/circuit_breaker.go
+++ b/rivershared/circuitbreaker/circuit_breaker.go
@@ -81,7 +81,8 @@ func (b *CircuitBreaker) ResetIfNotOpen() bool {
 
 // Trip "trips" the circuit breaker by counting an action towards opening it. If
 // the action causes the breaker to reach its limit within its window, the
-// breaker opens and the function returns true.
+// breaker opens and the function returns true. Subsequent calls to Trip after
+// the breaker is open will also return true.
 func (b *CircuitBreaker) Trip() bool {
 	if b.open {
 		return true
diff --git a/rivershared/riversharedmaintenance/river_shared_maintenance.go b/rivershared/riversharedmaintenance/river_shared_maintenance.go
index 39a48347..1ee8243e 100644
--- a/rivershared/riversharedmaintenance/river_shared_maintenance.go
+++ b/rivershared/riversharedmaintenance/river_shared_maintenance.go
@@ -20,6 +20,12 @@ const (
 	LogPrefixRanSuccessfully = ": Ran successfully"
 	LogPrefixRunLoopStarted  = ": Run loop started"
 	LogPrefixRunLoopStopped  = ": Run loop stopped"
+
+	// TimeoutDefault is a reasonable timeout for any large maintenance-related
+	// queries. Some maintainers may opt to switch to their own timeout, but
+	// this one should generally be used unless there's a good reason to have a
+	// specific version.
+	TimeoutDefault = 30 * time.Second
 )
 
 // Constants related to JobCleaner.