skip concurrent proof limit for agg proofs

op-proposer/flags/flags.go

@@ -130,7 +130,7 @@ var (
 	MaxConcurrentProofRequestsFlag = &cli.Uint64Flag{
 		Name:    "max-concurrent-proof-requests",
 		Usage:   "Maximum number of proofs to generate concurrently",
-		Value:   10,
+		Value:   20,
 		EnvVars: prefixEnvVars("MAX_CONCURRENT_PROOF_REQUESTS"),
 	}
 	TxCacheOutDirFlag = &cli.StringFlag{

op-proposer/proposer/prove.go

@@ -37,7 +37,7 @@ func (l *L2OutputSubmitter) ProcessPendingProofs() error {
 
 		timeout := uint64(time.Now().Unix()) > req.ProofRequestTime+l.DriverSetup.Cfg.MaxProofTime
 		// ZTODO: Talk to Succinct about logic of different statuses
-		if timeout {
+		if timeout || status == "PROOF_UNCLAIMED" {
 			// update status in db to "FAILED"
 			l.Log.Info("proof timed out", "id", req.ProverRequestID)
 			err = l.db.UpdateProofStatus(req.ID, "FAILED")
@@ -84,24 +84,29 @@ func (l *L2OutputSubmitter) RequestQueuedProofs(ctx context.Context) error {
 	if err != nil {
 		return fmt.Errorf("failed to get unrequested proofs: %w", err)
 	}
-
-	currentRequestedProofs, err := l.db.CountRequestedProofs()
-	if err != nil {
-		return fmt.Errorf("failed to count requested proofs: %w", err)
-	}
-	if currentRequestedProofs >= int(l.Cfg.MaxConcurrentProofRequests) {
-		l.Log.Info("max concurrent proof requests reached, waiting for next cycle")
+	if nextProofToRequest == nil {
 		return nil
 	}
+
 	if nextProofToRequest.Type == proofrequest.TypeAGG {
 		blockNumber, blockHash, err := l.checkpointBlockHash(ctx)
 		if err != nil {
 			l.Log.Error("failed to checkpoint block hash", "err", err)
 			return err
 		}
 		l.db.AddL1BlockInfoToAggRequest(nextProofToRequest.StartBlock, nextProofToRequest.EndBlock, blockNumber, blockHash.Hex())
+	} else {
+		currentRequestedProofs, err := l.db.CountRequestedProofs()
+		if err != nil {
+			return fmt.Errorf("failed to count requested proofs: %w", err)
+		}
+		if currentRequestedProofs >= int(l.Cfg.MaxConcurrentProofRequests) {
+			l.Log.Info("max concurrent proof requests reached, waiting for next cycle")
+			return nil
+		}
 	}
 	go func(p ent.ProofRequest) {
+		l.Log.Info("requesting proof from server", "proof", p)
 		err = l.db.UpdateProofStatus(nextProofToRequest.ID, "REQ")
 		if err != nil {
 			l.Log.Error("failed to update proof status", "err", err)

op-proposer/proposer/span_batches.go

@@ -66,7 +66,7 @@ func (l *L2OutputSubmitter) DeriveNewSpanBatches(ctx context.Context) error {
 
 		tmpStart := nextBlock
 		for {
-			maxEnd := tmpStart + l.DriverSetup.Cfg.MaxBlockRangePerSpanProof
+			maxEnd := tmpStart + l.DriverSetup.Cfg.MaxBlockRangePerSpanProof - 1
 			tmpEnd := uint64(math.Min(float64(maxEnd), float64(end)))
 
 			// insert the new span into the db to be requested in the future