INNER CODE UNIT · Go

execTimeout

redpanda-data/connect · benchmarking/aws/runner/main.go:287

	execTimeout := warmup + duration + execTimeoutSlack

	// A soak point runs far longer than a sweep point, so the fixed cadences
	// a short run tolerates would otherwise silently corrupt the run: the
	// per-minute heartbeat would overflow SSM's ~24KB stdout cap over many
	// hours, the 10s Prometheus scrape would accumulate gigabytes on disk and
	// in S3, and a mid-run crash would lose the entire window's data. See
	// matrix.go's benchScriptArgs for how these three feed the rendered
	// script.
	var heartbeatSec, promScrapeSec, checkpointSec int
	var expectedRecordsPerSec float64
	if s.Soak {
		totalSec := int((warmup + duration).Seconds())
		heartbeatSec = max(soakDefaultHeartbeatSec, totalSec/soakMaxHeartbeats)
		promScrapeSec = soakPromScrapeSec
		checkpointSec = soakCheckpointSec
		if s.Workload != nil {
			expectedRecordsPerSec = float64(s.Workload.WriteRatePerSec)

View source record →