batch := NewBatch[TestItem](BatchConfig[TestItem]{
		Limit:         limit,
		Store:         store,
		CommitTimeout: 5 * time.Minute,
		Log: func(ctx context.Context, err error, id string, errKind ...any) {
			t.Log([]any{err, id, errKind}...)
		},
	})

	for i := 0; i < int(limit); i++ {
		if err := batch.Add(testItem); err != nil {
			t.Fatalf("failed to add %v; %v", i, err)
		}
	}

        });
    }

    /**
     * Gets a web configuration by its ID.
     *
     * @param id The ID of the web configuration
     * @return Optional containing the web configuration if found
     */
    public OptionalEntity<WebConfig> getWebConfig(final String id) {
        return webConfigBhv.selectByPK(id);
    }

    /**
     * Gets a web configuration by its name.

     *
     * @param id the unique identifier of the crawling information record
     * @return an OptionalEntity containing the CrawlingInfo if found, empty otherwise
     */
    public OptionalEntity<CrawlingInfo> getCrawlingInfo(final String id) {
        return crawlingInfoBhv.selectByPK(id);
    }

    /**

		return nil, err
	}
	var h healingTracker
	_, err = h.UnmarshalMsg(b)
	if err != nil {
		return nil, err
	}
	if h.ID != diskID && h.ID != "" {
		return nil, fmt.Errorf("loadHealingTracker: drive id mismatch expected %s, got %s", h.ID, diskID)
	}
	h.disk = disk
	h.ID = diskID
	h.mu = &sync.RWMutex{}
	return &h, nil
}

// newHealingTracker will create a new healing tracker for the disk.

        response.jobLogId("test-id").status(Status.OK);
        assertEquals("test-id", response.jobLogId);
        assertEquals(0, response.status);
    }

    @Test
    public void test_ApiStartJobResponse_result() {
        final ApiStartJobResponse response = new ApiStartJobResponse();
        response.jobLogId("log-id-xyz").status(Status.OK);
        final ApiResult result = response.result();

    validations:
      required: true

  - type: textarea
    id: what-did-you-do
    attributes:
      label: "What did you do?"
      description: "If possible, provide a recipe for reproducing the error. A complete runnable program is good. A link on [go.dev/play](https://go.dev/play) is best."
    validations:
      required: true

  - type: textarea
    id: actual-behavior
    attributes:
      label: "What did you see happen?"

    private static final long serialVersionUID = 1L;

    private OptionalEntity<CrawlingInfo> crawlingInfo;

    public String getId() {
        return asDocMeta().id();
    }

    public void setId(final String id) {
        asDocMeta().id(id);
    }

    public Long getVersionNo() {
        return asDocMeta().version();
    }

    public void setVersionNo(final Long version) {

        assertContains(result.getErrors().get(0), "duplicate execution with id a");
        assertContains(result.getErrors().get(1), "duplicate execution with id default");
        assertContains(result.getErrors().get(2), "duplicate execution with id c");
        assertContains(result.getErrors().get(3), "duplicate execution with id b");
    }

    @Test
    void testReservedRepositoryId() throws Exception {

        assertEquals("ProtwordsItem [id=123, inputs=testword, newInputs=null]", item.toString());

        item.setNewInput("newword");
        assertEquals("ProtwordsItem [id=123, inputs=testword, newInputs=newword]", item.toString());

        ProtwordsItem item2 = new ProtwordsItem(0, "createword");
        assertEquals("ProtwordsItem [id=0, inputs=createword, newInputs=createword]", item2.toString());
    }

		diskStats[disk.PoolIndex].TotalSpace += disk.TotalSpace
	}

	stopTime := meta.StoppedAt
	r = rebalanceAdminStatus{
		ID:        meta.ID,
		StoppedAt: meta.StoppedAt,
		Pools:     make([]rebalancePoolStatus, len(meta.PoolStats)),
	}
	for i, ps := range meta.PoolStats {
		r.Pools[i] = rebalancePoolStatus{
			ID:     i,
			Status: ps.Info.Status.String(),