Axiom Data Workflow

简体中文 · Development

axiom-data-workflow is the public, application-neutral contract package for the production Axiom workflow service. It defines immutable workflow revisions, digest-addressed inputs and outputs, batch and Kafka ingestion requests, durable execution observations, checkpoints, lineage, terminal receipts, and the authenticated HTTP client.

The package contains no platform authority. Workflow, idempotency, execution, checkpoint, lineage, receipt, evidence, and audit state is owned by the Axiom service in KingbaseES (KES).

Production contracts

Supported imports are available from juntai.sdk.axiom.data_workflow:

  • WorkflowRevisionCreate and WorkflowRevision bind one canonical revision to an immutable application release, topology revision, and generic runtime digest.
  • IngestionRequest, ObjectReference, and KafkaRange describe exact batch or bounded continuous inputs.
  • WorkflowExecution, ExecutionAttempt, and ExecutionState expose durable execution and retry state.
  • WorkflowCheckpoint, LineageEdge, and ExecutionReceipt expose recovery and value-free provenance evidence.
  • AxiomWorkflowClient calls the authenticated production API and requires a request identity for every authorization/audit decision.

All revisions and receipts are validated against canonical SHA-256 identities. Mutable runtime labels and unqualified object locations are rejected.

Client example

from juntai.sdk.axiom.data_workflow import AxiomWorkflowClient

client = AxiomWorkflowClient("https://axiom.internal", workload_token)
execution = client.get_execution(
    "tenant-1",
    "application-1",
    "execution-1",
    request_id="observe-execution-1",
)
receipt = client.get_receipt(
    "tenant-1",
    "application-1",
    execution.execution_id,
    request_id="receipt-execution-1",
)

Create and ingestion operations accept the typed request contracts plus an idempotency key. Cancellation and replay use the execution resource endpoints and preserve their request identities in the KES audit chain.

Compatibility workflow abstractions

The earlier dataframe workflow abstractions remain lazy imports for existing application packages. Importing production service contracts does not load Polars, NumPy, or PyArrow. Scheduling, provider access, checkpointing, and execution stay outside application workflow classes.

Verification

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

See the Axiom orchestrator repository for the production HTTP service, KES migration, provider bindings, and live two-application acceptance.

License

See LICENSE.

Project links

Key dates

PyPI data
Data sourced directly from PyPI's database.
  • Released:
Latest release

1 maintainer

PyPI data
Data sourced directly from PyPI's database.
Avatar for vanzeph from gravatar.com vanzeph

Credits

Author: Juntai Team

Requires

Python >=3.11

Report project as malware

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_workflow-2.0.0.tar.gz (40.6 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_workflow-2.0.0-py3-none-any.whl (25.9 kB view details)

Uploaded Python 3

File details

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

File metadata

  • Download URL: axiom_data_workflow-2.0.0.tar.gz
  • Upload date:
  • Size: 40.6 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/7.0.0 CPython/3.13.14

File hashes

Hashes for axiom_data_workflow-2.0.0.tar.gz
Algorithm Hash digest
SHA256 1afbaefe97127777203abe132ba5c4d6c2c6feaac26f4f39fef8212aa6685e0d
MD5 ed010cddf11da140dcde9683116ca82e
BLAKE2b-256 10dc01d8ad6de8a6e15c8327482a142f3b597013938b36efd2295fc0469e40e1

See more details on using hashes here.

Provenance

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

Publisher: publish-python.yml on zephytiju/AxiomDataWorkflow

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_workflow-2.0.0-py3-none-any.whl.

File metadata

File hashes

Hashes for axiom_data_workflow-2.0.0-py3-none-any.whl
Algorithm Hash digest
SHA256 b917a430d2bcad636adae7e70653b75bb1f4d1e1f7ad3c7dcb76b16606a01812
MD5 fe58db47920daf1ac450f746a11a13d1
BLAKE2b-256 725781da71a5a9ef2e820240f3574e4a05ef7b3c202d6451f993e50b4af64bce

See more details on using hashes here.

Provenance

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

Publisher: publish-python.yml on zephytiju/AxiomDataWorkflow

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