Create Batch

BatchCreateResponse batches().create(, )

POST/api/v2/batches

Create a batch over a source directory and start processing asynchronously.

ParametersExpand Collapse

BatchCreateParams params

Optional<String> organizationId

Optional<String> projectId

Config config

Batch configuration snapshot to apply to this source directory.

Job job

Job to create for each file in the source directory.

String configurationId

Product configuration ID or built-in preset ID matching the job type.

Type type

Product job type to run for each source directory file.

One of the following:

PARSE_V2("parse_v2")

EXTRACT_V2("extract_v2")

String sourceDirectoryId

Directory whose files should be processed.

ReturnsExpand Collapse

class BatchCreateResponse:

A top-level batch.

Example: { “id”: “bat-aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee”, “project_id”: “prj-aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee”, “source_directory_id”: “dir-aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee”, “config”: { “job”: { “type”: “parse_v2”, “configuration_id”: “cfg-PARSE_AGENTIC” } }, “status”: “COMPLETED”, “results”: [ { “source_directory_file_id”: “dfl-aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee”, “job_reference”: { “type”: “parse_v2”, “id”: “pjb-aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee” }, “error_message”: null } ] }

Batch-level FAILED means the orchestration failed and cannot provide a reliable per-file result set. results is only populated when explicitly requested with expand=results and may be null while a batch is still running.

String id

Unique identifier

Config config

Batch configuration snapshot.

Job job

Job to create for each file in the source directory.

String configurationId

Product configuration ID or built-in preset ID matching the job type.

Type type

Product job type to run for each source directory file.

One of the following:

PARSE_V2("parse_v2")

EXTRACT_V2("extract_v2")

String projectId

Project this batch belongs to.

String sourceDirectoryId

Directory being processed.

Status status

Current batch status.

One of the following:

PENDING("PENDING")

THROTTLED("THROTTLED")

RUNNING("RUNNING")

COMPLETED("COMPLETED")

FAILED("FAILED")

CANCELLED("CANCELLED")

Optional<LocalDateTime> createdAt

Creation datetime

formatdate-time

Optional<List<Result>> results

Expanded per-file result mappings. Null unless requested with expand=results, or while the batch is still running.

String sourceDirectoryFileId

Source directory file processed by this batch.

Optional<String> errorMessage

Batch-level mapping error if the system could not create or associate a job for this source file.

Optional<JobReference> jobReference

Reference to a job produced by a batch.

Example: { “type”: “parse_v2”, “id”: “pjb-aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee” }

String id

Job ID, such as a parse job ID.

Type type

Type of job produced for the file.

One of the following:

PARSE_V2("parse_v2")

EXTRACT_V2("extract_v2")

Optional<LocalDateTime> updatedAt

Update datetime

formatdate-time

Create Batch

package com.llamacloud_prod.api.example;

import com.llamacloud_prod.api.client.LlamaCloudClient;
import com.llamacloud_prod.api.client.okhttp.LlamaCloudOkHttpClient;
import com.llamacloud_prod.api.models.batches.BatchCreateParams;
import com.llamacloud_prod.api.models.batches.BatchCreateResponse;

public final class Main {
    private Main() {}

    public static void main(String[] args) {
        LlamaCloudClient client = LlamaCloudOkHttpClient.fromEnv();

        BatchCreateParams params = BatchCreateParams.builder()
            .config(BatchCreateParams.Config.builder()
                .job(BatchCreateParams.Config.Job.builder()
                    .configurationId("cfg-PARSE_AGENTIC")
                    .type(BatchCreateParams.Config.Job.Type.PARSE_V2)
                    .build())
                .build())
            .sourceDirectoryId("dir-aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee")
            .build();
        BatchCreateResponse batch = client.batches().create(params);
    }
}

{
  "id": "id",
  "config": {
    "job": {
      "configuration_id": "cfg-PARSE_AGENTIC",
      "type": "parse_v2"
    }
  },
  "project_id": "project_id",
  "source_directory_id": "source_directory_id",
  "status": "PENDING",
  "created_at": "2019-12-27T18:11:19.117Z",
  "results": [
    {
      "source_directory_file_id": "dfl-aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
      "error_message": "error_message",
      "job_reference": {
        "id": "pjb-aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
        "type": "parse_v2"
      }
    }
  ],
  "updated_at": "2019-12-27T18:11:19.117Z"
}

Returns Examples

{
  "id": "id",
  "config": {
    "job": {
      "configuration_id": "cfg-PARSE_AGENTIC",
      "type": "parse_v2"
    }
  },
  "project_id": "project_id",
  "source_directory_id": "source_directory_id",
  "status": "PENDING",
  "created_at": "2019-12-27T18:11:19.117Z",
  "results": [
    {
      "source_directory_file_id": "dfl-aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
      "error_message": "error_message",
      "job_reference": {
        "id": "pjb-aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
        "type": "parse_v2"
      }
    }
  ],
  "updated_at": "2019-12-27T18:11:19.117Z"
}