---
title: prefactor_core
editUrl: true
head: []
template: doc
sidebar:
  hidden: false
  attrs: {}
pagefind: true
draft: false
---

# prefactor_core

* [prefactor_core package](prefactor_core.md)
  * [`AgentInstance`](prefactor_core.md#prefactor_core.AgentInstance)
    * [`AgentInstance.id`](prefactor_core.md#prefactor_core.AgentInstance.id)
    * [`AgentInstance.agent_id`](prefactor_core.md#prefactor_core.AgentInstance.agent_id)
    * [`AgentInstance.status`](prefactor_core.md#prefactor_core.AgentInstance.status)
    * [`AgentInstance.created_at`](prefactor_core.md#prefactor_core.AgentInstance.created_at)
    * [`AgentInstance.started_at`](prefactor_core.md#prefactor_core.AgentInstance.started_at)
    * [`AgentInstance.finished_at`](prefactor_core.md#prefactor_core.AgentInstance.finished_at)
    * [`AgentInstance.metadata`](prefactor_core.md#prefactor_core.AgentInstance.metadata)
    * [`AgentInstance.agent_id`](prefactor_core.md#id0)
    * [`AgentInstance.created_at`](prefactor_core.md#id1)
    * [`AgentInstance.finished_at`](prefactor_core.md#id2)
    * [`AgentInstance.id`](prefactor_core.md#id3)
    * [`AgentInstance.metadata`](prefactor_core.md#id4)
    * [`AgentInstance.started_at`](prefactor_core.md#id5)
    * [`AgentInstance.status`](prefactor_core.md#id6)
  * [`AgentInstanceHandle`](prefactor_core.md#prefactor_core.AgentInstanceHandle)
    * [`AgentInstanceHandle.create_span()`](prefactor_core.md#prefactor_core.AgentInstanceHandle.create_span)
    * [`AgentInstanceHandle.finish()`](prefactor_core.md#prefactor_core.AgentInstanceHandle.finish)
    * [`AgentInstanceHandle.finish_span()`](prefactor_core.md#prefactor_core.AgentInstanceHandle.finish_span)
    * [`AgentInstanceHandle.id`](prefactor_core.md#prefactor_core.AgentInstanceHandle.id)
    * [`AgentInstanceHandle.span()`](prefactor_core.md#prefactor_core.AgentInstanceHandle.span)
    * [`AgentInstanceHandle.start()`](prefactor_core.md#prefactor_core.AgentInstanceHandle.start)
  * [`ClientAlreadyInitializedError`](prefactor_core.md#prefactor_core.ClientAlreadyInitializedError)
  * [`ClientNotInitializedError`](prefactor_core.md#prefactor_core.ClientNotInitializedError)
  * [`InMemoryQueue`](prefactor_core.md#prefactor_core.InMemoryQueue)
    * [`InMemoryQueue.close()`](prefactor_core.md#prefactor_core.InMemoryQueue.close)
    * [`InMemoryQueue.closed`](prefactor_core.md#prefactor_core.InMemoryQueue.closed)
    * [`InMemoryQueue.get()`](prefactor_core.md#prefactor_core.InMemoryQueue.get)
    * [`InMemoryQueue.put()`](prefactor_core.md#prefactor_core.InMemoryQueue.put)
    * [`InMemoryQueue.size()`](prefactor_core.md#prefactor_core.InMemoryQueue.size)
  * [`InstanceNotFoundError`](prefactor_core.md#prefactor_core.InstanceNotFoundError)
  * [`Operation`](prefactor_core.md#prefactor_core.Operation)
    * [`Operation.type`](prefactor_core.md#prefactor_core.Operation.type)
    * [`Operation.payload`](prefactor_core.md#prefactor_core.Operation.payload)
    * [`Operation.timestamp`](prefactor_core.md#prefactor_core.Operation.timestamp)
    * [`Operation.idempotency_key`](prefactor_core.md#prefactor_core.Operation.idempotency_key)
    * [`Operation.metadata`](prefactor_core.md#prefactor_core.Operation.metadata)
    * [`Operation.idempotency_key`](prefactor_core.md#id7)
    * [`Operation.metadata`](prefactor_core.md#id8)
    * [`Operation.payload`](prefactor_core.md#id9)
    * [`Operation.timestamp`](prefactor_core.md#id10)
    * [`Operation.type`](prefactor_core.md#id11)
  * [`OperationError`](prefactor_core.md#prefactor_core.OperationError)
  * [`OperationType`](prefactor_core.md#prefactor_core.OperationType)
    * [`OperationType.CREATE_SPAN`](prefactor_core.md#prefactor_core.OperationType.CREATE_SPAN)
    * [`OperationType.FINISH_AGENT_INSTANCE`](prefactor_core.md#prefactor_core.OperationType.FINISH_AGENT_INSTANCE)
    * [`OperationType.FINISH_SPAN`](prefactor_core.md#prefactor_core.OperationType.FINISH_SPAN)
    * [`OperationType.REGISTER_AGENT_INSTANCE`](prefactor_core.md#prefactor_core.OperationType.REGISTER_AGENT_INSTANCE)
    * [`OperationType.START_AGENT_INSTANCE`](prefactor_core.md#prefactor_core.OperationType.START_AGENT_INSTANCE)
  * [`PrefactorCoreClient`](prefactor_core.md#prefactor_core.PrefactorCoreClient)
    * [`PrefactorCoreClient.close()`](prefactor_core.md#prefactor_core.PrefactorCoreClient.close)
    * [`PrefactorCoreClient.create_agent_instance()`](prefactor_core.md#prefactor_core.PrefactorCoreClient.create_agent_instance)
    * [`PrefactorCoreClient.create_span()`](prefactor_core.md#prefactor_core.PrefactorCoreClient.create_span)
    * [`PrefactorCoreClient.finish_span()`](prefactor_core.md#prefactor_core.PrefactorCoreClient.finish_span)
    * [`PrefactorCoreClient.initialize()`](prefactor_core.md#prefactor_core.PrefactorCoreClient.initialize)
    * [`PrefactorCoreClient.instance_manager`](prefactor_core.md#prefactor_core.PrefactorCoreClient.instance_manager)
    * [`PrefactorCoreClient.span()`](prefactor_core.md#prefactor_core.PrefactorCoreClient.span)
  * [`PrefactorCoreConfig`](prefactor_core.md#prefactor_core.PrefactorCoreConfig)
    * [`PrefactorCoreConfig.http_config`](prefactor_core.md#prefactor_core.PrefactorCoreConfig.http_config)
    * [`PrefactorCoreConfig.queue_config`](prefactor_core.md#prefactor_core.PrefactorCoreConfig.queue_config)
    * [`PrefactorCoreConfig.schema_registry`](prefactor_core.md#prefactor_core.PrefactorCoreConfig.schema_registry)
    * [`PrefactorCoreConfig.http_config`](prefactor_core.md#id12)
    * [`PrefactorCoreConfig.model_config`](prefactor_core.md#prefactor_core.PrefactorCoreConfig.model_config)
    * [`PrefactorCoreConfig.queue_config`](prefactor_core.md#id13)
    * [`PrefactorCoreConfig.schema_registry`](prefactor_core.md#id14)
  * [`PrefactorCoreError`](prefactor_core.md#prefactor_core.PrefactorCoreError)
  * [`PrefactorTelemetryFailureError`](prefactor_core.md#prefactor_core.PrefactorTelemetryFailureError)
  * [`Queue`](prefactor_core.md#prefactor_core.Queue)
    * [`Queue.close()`](prefactor_core.md#prefactor_core.Queue.close)
    * [`Queue.closed`](prefactor_core.md#prefactor_core.Queue.closed)
    * [`Queue.get()`](prefactor_core.md#prefactor_core.Queue.get)
    * [`Queue.put()`](prefactor_core.md#prefactor_core.Queue.put)
    * [`Queue.size()`](prefactor_core.md#prefactor_core.Queue.size)
  * [`QueueClosedError`](prefactor_core.md#prefactor_core.QueueClosedError)
  * [`QueueConfig`](prefactor_core.md#prefactor_core.QueueConfig)
    * [`QueueConfig.num_workers`](prefactor_core.md#prefactor_core.QueueConfig.num_workers)
    * [`QueueConfig.max_retries`](prefactor_core.md#prefactor_core.QueueConfig.max_retries)
    * [`QueueConfig.retry_delay_base`](prefactor_core.md#prefactor_core.QueueConfig.retry_delay_base)
    * [`QueueConfig.max_retries`](prefactor_core.md#id15)
    * [`QueueConfig.model_config`](prefactor_core.md#prefactor_core.QueueConfig.model_config)
    * [`QueueConfig.num_workers`](prefactor_core.md#id16)
    * [`QueueConfig.retry_delay_base`](prefactor_core.md#id17)
  * [`SchemaRegistry`](prefactor_core.md#prefactor_core.SchemaRegistry)
    * [`SchemaRegistry.get()`](prefactor_core.md#prefactor_core.SchemaRegistry.get)
    * [`SchemaRegistry.has_schema()`](prefactor_core.md#prefactor_core.SchemaRegistry.has_schema)
    * [`SchemaRegistry.list_schemas()`](prefactor_core.md#prefactor_core.SchemaRegistry.list_schemas)
    * [`SchemaRegistry.merge()`](prefactor_core.md#prefactor_core.SchemaRegistry.merge)
    * [`SchemaRegistry.register()`](prefactor_core.md#prefactor_core.SchemaRegistry.register)
    * [`SchemaRegistry.register_result()`](prefactor_core.md#prefactor_core.SchemaRegistry.register_result)
    * [`SchemaRegistry.register_type()`](prefactor_core.md#prefactor_core.SchemaRegistry.register_type)
    * [`SchemaRegistry.register_unsafe()`](prefactor_core.md#prefactor_core.SchemaRegistry.register_unsafe)
    * [`SchemaRegistry.to_agent_schema_version()`](prefactor_core.md#prefactor_core.SchemaRegistry.to_agent_schema_version)
  * [`Span`](prefactor_core.md#prefactor_core.Span)
    * [`Span.id`](prefactor_core.md#prefactor_core.Span.id)
    * [`Span.instance_id`](prefactor_core.md#prefactor_core.Span.instance_id)
    * [`Span.parent_span_id`](prefactor_core.md#prefactor_core.Span.parent_span_id)
    * [`Span.schema_name`](prefactor_core.md#prefactor_core.Span.schema_name)
    * [`Span.status`](prefactor_core.md#prefactor_core.Span.status)
    * [`Span.payload`](prefactor_core.md#prefactor_core.Span.payload)
    * [`Span.created_at`](prefactor_core.md#prefactor_core.Span.created_at)
    * [`Span.started_at`](prefactor_core.md#prefactor_core.Span.started_at)
    * [`Span.finished_at`](prefactor_core.md#prefactor_core.Span.finished_at)
    * [`Span.created_at`](prefactor_core.md#id18)
    * [`Span.finished_at`](prefactor_core.md#id19)
    * [`Span.id`](prefactor_core.md#id20)
    * [`Span.instance_id`](prefactor_core.md#id21)
    * [`Span.parent_span_id`](prefactor_core.md#id22)
    * [`Span.payload`](prefactor_core.md#id23)
    * [`Span.schema_name`](prefactor_core.md#id24)
    * [`Span.started_at`](prefactor_core.md#id25)
    * [`Span.status`](prefactor_core.md#id26)
  * [`SpanContext`](prefactor_core.md#prefactor_core.SpanContext)
    * [`SpanContext.cancel()`](prefactor_core.md#prefactor_core.SpanContext.cancel)
    * [`SpanContext.complete()`](prefactor_core.md#prefactor_core.SpanContext.complete)
    * [`SpanContext.fail()`](prefactor_core.md#prefactor_core.SpanContext.fail)
    * [`SpanContext.finish()`](prefactor_core.md#prefactor_core.SpanContext.finish)
    * [`SpanContext.id`](prefactor_core.md#prefactor_core.SpanContext.id)
    * [`SpanContext.set_result()`](prefactor_core.md#prefactor_core.SpanContext.set_result)
    * [`SpanContext.start()`](prefactor_core.md#prefactor_core.SpanContext.start)
  * [`SpanContextStack`](prefactor_core.md#prefactor_core.SpanContextStack)
    * [`SpanContextStack.depth()`](prefactor_core.md#prefactor_core.SpanContextStack.depth)
    * [`SpanContextStack.get_stack()`](prefactor_core.md#prefactor_core.SpanContextStack.get_stack)
    * [`SpanContextStack.is_empty()`](prefactor_core.md#prefactor_core.SpanContextStack.is_empty)
    * [`SpanContextStack.peek()`](prefactor_core.md#prefactor_core.SpanContextStack.peek)
    * [`SpanContextStack.pop()`](prefactor_core.md#prefactor_core.SpanContextStack.pop)
    * [`SpanContextStack.push()`](prefactor_core.md#prefactor_core.SpanContextStack.push)
  * [`SpanNotFoundError`](prefactor_core.md#prefactor_core.SpanNotFoundError)
  * [`TaskExecutor`](prefactor_core.md#prefactor_core.TaskExecutor)
    * [`TaskExecutor.start()`](prefactor_core.md#prefactor_core.TaskExecutor.start)
    * [`TaskExecutor.stop()`](prefactor_core.md#prefactor_core.TaskExecutor.stop)
  * [`generate_idempotency_key()`](prefactor_core.md#prefactor_core.generate_idempotency_key)
  * [`validate_idempotency_key()`](prefactor_core.md#prefactor_core.validate_idempotency_key)
  * [Subpackages](prefactor_core.md#subpackages)
    * [prefactor_core.managers package](prefactor_core.managers.md)
      * [`AgentInstanceHandle`](prefactor_core.managers.md#prefactor_core.managers.AgentInstanceHandle)
      * [`AgentInstanceManager`](prefactor_core.managers.md#prefactor_core.managers.AgentInstanceManager)
      * [`SpanManager`](prefactor_core.managers.md#prefactor_core.managers.SpanManager)
      * [Submodules](prefactor_core.managers.md#submodules)
    * [prefactor_core.queue package](prefactor_core.queue.md)
      * [`InMemoryQueue`](prefactor_core.queue.md#prefactor_core.queue.InMemoryQueue)
      * [`Queue`](prefactor_core.queue.md#prefactor_core.queue.Queue)
      * [`QueueClosedError`](prefactor_core.queue.md#prefactor_core.queue.QueueClosedError)
      * [`TaskExecutor`](prefactor_core.queue.md#prefactor_core.queue.TaskExecutor)
      * [Submodules](prefactor_core.queue.md#submodules)
  * [Submodules](prefactor_core.md#submodules)
    * [prefactor_core.client module](prefactor_core.client.md)
      * [`PrefactorCoreClient`](prefactor_core.client.md#prefactor_core.client.PrefactorCoreClient)
    * [prefactor_core.config module](prefactor_core.config.md)
      * [`PrefactorCoreConfig`](prefactor_core.config.md#prefactor_core.config.PrefactorCoreConfig)
      * [`QueueConfig`](prefactor_core.config.md#prefactor_core.config.QueueConfig)
    * [prefactor_core.context_stack module](prefactor_core.context_stack.md)
      * [`SpanContextStack`](prefactor_core.context_stack.md#prefactor_core.context_stack.SpanContextStack)
    * [prefactor_core.exceptions module](prefactor_core.exceptions.md)
      * [`ClientAlreadyInitializedError`](prefactor_core.exceptions.md#prefactor_core.exceptions.ClientAlreadyInitializedError)
      * [`ClientNotInitializedError`](prefactor_core.exceptions.md#prefactor_core.exceptions.ClientNotInitializedError)
      * [`InstanceNotFoundError`](prefactor_core.exceptions.md#prefactor_core.exceptions.InstanceNotFoundError)
      * [`OperationError`](prefactor_core.exceptions.md#prefactor_core.exceptions.OperationError)
      * [`PrefactorCoreError`](prefactor_core.exceptions.md#prefactor_core.exceptions.PrefactorCoreError)
      * [`PrefactorTelemetryFailureError`](prefactor_core.exceptions.md#prefactor_core.exceptions.PrefactorTelemetryFailureError)
      * [`SpanNotFoundError`](prefactor_core.exceptions.md#prefactor_core.exceptions.SpanNotFoundError)
    * [prefactor_core.models module](prefactor_core.models.md)
      * [`AgentInstance`](prefactor_core.models.md#prefactor_core.models.AgentInstance)
      * [`Span`](prefactor_core.models.md#prefactor_core.models.Span)
    * [prefactor_core.operations module](prefactor_core.operations.md)
      * [`Operation`](prefactor_core.operations.md#prefactor_core.operations.Operation)
      * [`OperationType`](prefactor_core.operations.md#prefactor_core.operations.OperationType)
    * [prefactor_core.schema_registry module](prefactor_core.schema_registry.md)
      * [`SchemaRegistry`](prefactor_core.schema_registry.md#prefactor_core.schema_registry.SchemaRegistry)
    * [prefactor_core.span_context module](prefactor_core.span_context.md)
      * [`SpanContext`](prefactor_core.span_context.md#prefactor_core.span_context.SpanContext)
    * [prefactor_core.utils module](prefactor_core.utils.md)
      * [`generate_idempotency_key()`](prefactor_core.utils.md#prefactor_core.utils.generate_idempotency_key)
      * [`validate_idempotency_key()`](prefactor_core.utils.md#prefactor_core.utils.validate_idempotency_key)