← Python SDK / output

PYTHONPUBLIC API

fastsim.api.output

fastsim.api.output 的公共 Python API；签名从 FastSim 源码直接提取。

RunOutputError RunOutputPolicy RunOutputCommitReceipt RunOutputAbortReceipt RunOutputValidationReceipt RunOutputFileLease RunOutputReadbackLease RunOutputTransaction RunOutputService

公开符号 9

class

RunOutputError

L24

class RunOutputError(RuntimeError)

Stable fail-closed error raised by the output capability.

class

RunOutputPolicy

L39

class RunOutputPolicy(object)

Trusted deployment policy with a pre-opened canonical local root. The descriptor is private and never enters a Run document, ExecutionPlan, lockfile, manifest, or plugin grant. Each composed Run duplicates the pinned descriptor, so the caller may close its policy after ``open_plan`` returns.

closed

RunOutputPolicy.closed(self) -> bool

RunOutputPolicy.close(self) -> None

class

RunOutputCommitReceipt

L197

class RunOutputCommitReceipt(object)

字段	类型	默认值
run_id	str	—
plugin_instance	str	—
transaction_id	str	—
logical_name	str	—
format	str	—
bytes_written	int	—
integrity	str	—
sha256	str \| None	—
committed_monotonic_ns	int	—
schema	str	field(default='fastsim-run-output-commit/2', init=False)

class

RunOutputAbortReceipt

L223

class RunOutputAbortReceipt(object)

字段	类型	默认值
run_id	str	—
plugin_instance	str	—
transaction_id	str	—
reason_code	str	—
bytes_written	int	—
preserved_incomplete	bool	—
incomplete_logical_name	str \| None	—
schema	str	field(default='fastsim-run-output-abort/1', init=False)

class

RunOutputValidationReceipt

L247

class RunOutputValidationReceipt(object)

Small format-neutral proof produced by an independent validator worker.

字段	类型	默认值
validator_schema	str	—
validation_profile	str	—
integrity	str	—
validated_bytes	int	—
content_sha256	str \| None	—
footer_identity	str	—
schema	str	field(default='fastsim-run-output-validation/2', init=False)

class

RunOutputFileLease

L280

class RunOutputFileLease(Protocol)

closed

RunOutputFileLease.closed(self) -> bool

bytes_written

RunOutputFileLease.bytes_written(self) -> int

handoff_to_worker

RunOutputFileLease.handoff_to_worker(self, worker_identity: int) -> None

write

RunOutputFileLease.write(self, data: memoryview) -> int

flush

RunOutputFileLease.flush(self) -> None

RunOutputFileLease.close(self) -> None

class

RunOutputReadbackLease

L297

class RunOutputReadbackLease(Protocol)

closed

RunOutputReadbackLease.closed(self) -> bool

size_bytes

RunOutputReadbackLease.size_bytes(self) -> int

handoff_to_worker

RunOutputReadbackLease.handoff_to_worker(self, worker_identity: int) -> None

readinto

RunOutputReadbackLease.readinto(self, buffer: memoryview) -> int

seek

RunOutputReadbackLease.seek(self, offset: int, whence: int=os.SEEK_SET) -> int

tell

RunOutputReadbackLease.tell(self) -> int

RunOutputReadbackLease.close(self) -> None

class

RunOutputTransaction

L316

class RunOutputTransaction(Protocol)

integrity

RunOutputTransaction.integrity(self) -> str

transaction_id

RunOutputTransaction.transaction_id(self) -> str

logical_name

RunOutputTransaction.logical_name(self) -> str

open_stream

RunOutputTransaction.open_stream(self) -> RunOutputFileLease

seal

RunOutputTransaction.seal(self, lease: RunOutputFileLease) -> None

open_readback

RunOutputTransaction.open_readback(self) -> RunOutputReadbackLease

confirm_validation

RunOutputTransaction.confirm_validation(self, readback_lease: RunOutputReadbackLease, validation_receipt: RunOutputValidationReceipt) -> None

commit

RunOutputTransaction.commit(self) -> RunOutputCommitReceipt

abort

RunOutputTransaction.abort(self, reason_code: str='PLUGIN_ABORTED') -> RunOutputAbortReceipt

class

RunOutputService

L344

class RunOutputService(Protocol)

service_id

RunOutputService.service_id(self) -> str

begin_primary

RunOutputService.begin_primary(self, logical_name: str, format: str, idempotency_key: str) -> RunOutputTransaction