Skip to main content

Axiom Data Pipeline Topology

简体中文 · Development

axiom-data-pipeline-topology owns production topology, validation, schedule, and immutable revision contracts. It validates bounded DAGs, exact runtime artifacts, resource requests, and security labels before a revision can be activated.

KESTopologyRepository is the persistence adapter. It accepts a native KES connection factory and stores immutable topology revisions, active revision pointers, schedules, leases, and observations in the Axiom KES schema. The package provides no process-local authority.

Public surface

  • TopologyRevisionCreate, TopologyRevision, and TopologyValidation
  • TopologyValidator, ExecutionGraph, TaskNode, and ResourceRequest
  • ScheduleDefinition, ScheduleKind, ScheduleState, and ScheduleObservation
  • KESTopologyRepository and TopologyService

Topology revision IDs equal the canonical SHA-256 digest of their complete content. Production nodes must reference exact artifact digests. Schedule kinds are manual, bounded interval, or continuous Kafka partition consumption.

Service flow

validate request -> create immutable KES revision -> activate exact revision
                                                \-> create/pause/resume schedule

The Axiom orchestrator exposes these operations through its authenticated HTTP API and owns schedule execution. This package never provisions Ray, Kafka, or other platform services.

Verification

python -m pytest
ruff check src tests
python -m build

License

See LICENSE.

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

axiom_data_pipeline_topology-2.0.0.tar.gz (26.7 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

axiom_data_pipeline_topology-2.0.0-py3-none-any.whl (22.6 kB view details)

Uploaded Python 3

File details

Details for the file axiom_data_pipeline_topology-2.0.0.tar.gz.

File metadata

File hashes

Hashes for axiom_data_pipeline_topology-2.0.0.tar.gz
Algorithm Hash digest
SHA256 8ec196e2ece0709a9edeb24cf74da258a7a1f3ae91914323f1daf9811b064c67
MD5 d67aea0155914b40b1fb8bc4d0dac4e6
BLAKE2b-256 c861ef89ef63a7821c78be09a9a9c4475eeec56d246bf8b353afb7bc44bbcbf8

See more details on using hashes here.

Provenance

The following attestation bundles were made for axiom_data_pipeline_topology-2.0.0.tar.gz:

Publisher: publish-python.yml on zephytiju/AxiomDataPipelineTopology

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file axiom_data_pipeline_topology-2.0.0-py3-none-any.whl.

File metadata

File hashes

Hashes for axiom_data_pipeline_topology-2.0.0-py3-none-any.whl
Algorithm Hash digest
SHA256 46de8afdd7200a8d36e5c725c57d29fe9927ea2876d672417a5aff69c551089c
MD5 0bab281b1bf923a12fb492eb757c2445
BLAKE2b-256 e3167ca664171eec909ade004d0fd3a69b35cb8bc4b53758610f2936507419fa

See more details on using hashes here.

Provenance

The following attestation bundles were made for axiom_data_pipeline_topology-2.0.0-py3-none-any.whl:

Publisher: publish-python.yml on zephytiju/AxiomDataPipelineTopology

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

Release history Release notifications | RSS feed

This release

2.0.0 This release

2 files

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page