Once a scenario is run, it is run to the end ( runn loadt ).

Makefile

@@ -21,16 +21,13 @@ test: cert
 race:
 	go test ./... -race
 
-test-loadt: cert
-	go test ./... -tags=loadt -count=1
-
 test-integration: cert
 	chmod 600 testdata/sshd/id_rsa
 	go test ./... -tags=integration -count=1
 
 test-all: cert
 	chmod 600 testdata/sshd/id_rsa
-	go test ./... -tags='integration loadt' -coverprofile=coverage.out -covermode=count
+	go test ./... -tags=integration -coverprofile=coverage.out -covermode=count
 
 benchmark: cert
 	go test -bench . -benchmem -run Benchmark | octocov-go-test-bench --tee > custom_metrics_benchmark.json

loadt.go

@@ -105,6 +105,7 @@ func (r *loadtResult) Report(w io.Writer) error {
 	if err != nil {
 		return err
 	}
+
 	data := map[string]any{
 		"NumberOfRunbooks": r.runbookCount,
 		"WarmUpTime":       r.warmUp.String(),

loadt_test.go

@@ -1,12 +1,11 @@
-//go:build loadt
-
 package runn
 
 import (
 	"context"
 	"testing"
 	"time"
 
+	"github.com/k1LoW/runn/testutil"
 	"github.com/ryo-yamaoka/otchkiss"
 	"github.com/ryo-yamaoka/otchkiss/setting"
 )
@@ -17,16 +16,21 @@ func TestLoadt(t *testing.T) {
 		concarent int
 	}{
 		{"testdata/book/include_main.yml", 2},
+		{"testdata/book/http_sleep.yml", 2},
 	}
+	hs := testutil.HTTPServer(t)
+	t.Setenv("TEST_HTTP_ENDPOINT", hs.URL)
 	for _, tt := range tests {
 		t.Run(tt.in, func(t *testing.T) {
 			t.Parallel()
-			opts := []Option{}
+			opts := []Option{
+				Scopes(ScopeAllowRunExec),
+			}
 			o, err := Load(tt.in, opts...)
 			if err != nil {
 				t.Error(err)
 			}
-			s, err := setting.New(tt.concarent, 0, 5*time.Second, 5*time.Second)
+			s, err := setting.New(tt.concarent, 0, 100*time.Microsecond, 100*time.Millisecond)
 			if err != nil {
 				t.Error(err)
 			}
@@ -37,6 +41,13 @@ func TestLoadt(t *testing.T) {
 			if err := ot.Start(context.Background()); err != nil {
 				t.Error(err)
 			}
+
+			if ot.Result.Succeeded() == 0 {
+				t.Error("no succeeded")
+			}
+			if ot.Result.Failed() != 0 {
+				t.Error("some failed")
+			}
 		})
 	}
 }

operator.go

@@ -1545,6 +1545,7 @@ func (ops *operators) RequestOne(ctx context.Context) error {
 	if !ops.profile {
 		ops.sw.Disable()
 	}
+	ctx = context.WithoutCancel(ctx)
 	result, err := ops.runN(ctx)
 	if err != nil {
 		return err

operator_test.go

@@ -303,13 +303,13 @@ func TestLoad(t *testing.T) {
 		{"testdata/book/**/*", "nonexistent", "", "", 0},
 		{"testdata/book/**/*", "", "eb33c9aed04a7f1e03c1a1246b5d7bdaefd903d3", "", 1},
 		{"testdata/book/**/*", "", "eb33c9a", "", 1},
-		{"testdata/book/**/*", "", "", "http", 13},
+		{"testdata/book/**/*", "", "", "http", 14},
 		{"testdata/book/**/*", "", "", "openapi3", 9},
-		{"testdata/book/**/*", "", "", "http,openapi3", 13},
+		{"testdata/book/**/*", "", "", "http,openapi3", 14},
 		{"testdata/book/**/*", "", "", "http and openapi3", 9},
 		{"testdata/book/**/*", "", "", "http and nothing", 0},
-		{"testdata/book/**/*", "", "", "http or nothing", 13},
-		{"testdata/book/**/*", "", "", "http and not openapi3", 4},
+		{"testdata/book/**/*", "", "", "http or nothing", 14},
+		{"testdata/book/**/*", "", "", "http and not openapi3", 5},
 		{"testdata/book/needs_3.yml", "", "", "", 1}, // Runbooks that are only in the needs section are not counted at Load
 	}
 

testdata/book/http_sleep.yml

@@ -0,0 +1,15 @@
+desc: Test using HTTP for loadt
+labels:
+  - http
+runners:
+  req:
+    endpoint: ${TEST_HTTP_ENDPOINT:-https:example.com}
+steps:
+  -
+    desc: Sleep for 3 second
+    req:
+      /sleep/3:
+        get:
+          body: null
+    test:
+      current.res.status == 200