Skip to content
Prefactor Docs

prefactor_http.endpoints.bulk module

prefactor_http.endpoints.bulk module

Section titled “prefactor_http.endpoints.bulk module”

Bulk endpoint client for the Prefactor API.

class prefactor_http.endpoints.bulk.BulkClient(http_client: PrefactorHttpClient)

Section titled “class prefactor_http.endpoints.bulk.BulkClient(http_client: PrefactorHttpClient)”

Bases: object

Client for bulk action operations.

Execute multiple POST actions in a single HTTP request. This endpoint allows you to batch multiple operations together, reducing the number of round trips to the API.

Key Features: : - Each item in the request is processed independently in its own database transaction

  • Processing stops early if any item returns an error
  • All successfully processed items up to the error are returned
  • Any unprocessed items (after the first error) are excluded from the result
  • All items must include a unique idempotency_key (minimum 8 characters)
  • Results are returned as a map keyed by idempotency_key

Example

Section titled “Example”
``
`

python request = BulkRequest(

items=[ : BulkItem( # type: ignore[call-arg] : _type=”agent_instances/register”, idempotency_key=”register-instance-001”, agent_id=”agent_123”, agent_version={“name”: “My Agent”, “external_identifier”: “v1.0.0”}, agent_schema_version={
> “external_identifier”: “v1.0.0”, > “span_type_schemas”: [
> > { > > : “name”: “agent:llm”, > > “title”: “LLM Call”, > > “params_schema”: { > >
> > > “type”: “object”, > > > “properties”: { > >
> > > > “model”: {“type”: “string”}, > > > > “prompt”: {“type”: “string”}, > >
> > > }, > > > “required”: [“model”, “prompt”], > >
> > }, > > “result_schema”: { > >
> > > “type”: “object”, > > > “properties”: { > >
> > > > “response”: {“type”: “string”}, > >
> > > }, > >
> > },
> > },
> ],
},
), BulkItem( # type: ignore[call-arg]

_type=”agent_spans/create”, idempotency_key=”create-span-001”, agent_instance_id=”instance_123”, schema_name=”agent:llm”, status=”active”,


),

]

) response = await client.bulk.execute(request) print(response.outputs[“create-span-001”].status)

``
`

async execute(request: BulkRequest) → BulkResponse

Section titled “async execute(request: BulkRequest) → BulkResponse”

Execute multiple queries/actions in a single request.