tests: Ensure node is synced before doing further queries

oasisprotocol · Feb 21, 2023 · a5ea3e5 · a5ea3e5
1 parent 2bbc7d9
commit a5ea3e5
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/go/oasis-node/cmd/debug/txsource/workload/queries.go b/go/oasis-node/cmd/debug/txsource/workload/queries.go
@@ -872,6 +872,14 @@ func (q *queries) Run(
 	for {
 		loopCtx, cancel := context.WithTimeout(ctx, queriesIterationTimeout)
 
+		// Ensure the node appears synced before doing queries. Given that nodes can be killed and
+		// held stopped for a while, they need to sync once they come back.
+		if isSynced, _ := q.control.IsSynced(loopCtx); !isSynced {
+			_ = q.control.WaitSync(loopCtx)
+			time.Sleep(1 * time.Second)
+			continue
+		}
+
 		err := q.doQueries(loopCtx, rng)
 		cancel()
 		switch {