Skip to main content
Pre-release

This release is a pre-release and may not be stable for production use.

CogFlow

CogFlow is a modular, SDK-first machine learning workflow management system built on Kubeflow Pipelines, MLflow, Kubernetes, and MinIO.

It provides a clean Python API for:

  • building production-grade ML pipelines
  • managing datasets and components
  • orchestrating federated learning workflows
  • enforcing consistent error handling and validation

CogFlow is designed for real infrastructure, not notebooks only.


Why CogFlow?

Modern ML platforms are powerful but fragmented:

  • Kubeflow Pipelines → great orchestration, weak ergonomics
  • MLflow → experiment tracking, limited workflow control
  • Kubernetes → powerful, but verbose and error-prone
  • Federated learning → no standard orchestration layer

CogFlow bridges these gaps by providing:

  • a stable Python SDK
  • safe lazy-loading of heavy dependencies
  • unified error handling
  • infrastructure-aware abstractions
  • zero circular imports

Core Features

🧩 Pipeline Orchestration

  • Lazy-loaded Kubeflow Pipelines client
  • Safe pipeline compilation and submission
  • Runtime environment injection
  • Kubernetes service lifecycle management

📦 Component Management

  • YAML-based component registry
  • MinIO-backed component storage
  • Automatic component registration
  • Runtime-safe component loading

📊 Dataset Management

  • Dataset registration and metadata retrieval
  • Secure dataset downloads
  • Silent deletes with strict error semantics
  • Pluggable storage backends

🤝 Federated Learning

  • Auto-generated FL pipelines
  • Dynamic pipeline signatures
  • Connector-based and dataspace-based workflows
  • Region-aware scheduling with node selectors

🧠 Unified Error Handling

  • Strongly typed error hierarchy
  • Context-aware exception wrapping
  • API-ready error serialization
  • Zero silent failures

Architecture Overview

CogFlow follows a layered SDK architecture:

cogflow/ ├── core/ │ ├── pipelines/ # Kubeflow orchestration & FL pipelines │ ├── datasets/ # Dataset lifecycle management │ ├── components/ # Component registry & YAML handling │ └── models/ # (future extension) │ ├── utils/ │ ├── common.py # UUIDs, paths, Kubernetes helpers │ ├── network.py # HTTP utilities with retry & streaming │ ├── storage.py # MinIO client abstraction │ └── exceptions.py # Unified error framework │ ├── config.py └── api.py

Download files

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

Source Distribution

cogflow-3.0.0b14.tar.gz (368.6 kB view details)

Uploaded Source

Built Distribution

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

cogflow-3.0.0b14-py3-none-any.whl (421.9 kB view details)

Uploaded Python 3

File details

Details for the file cogflow-3.0.0b14.tar.gz.

File metadata

  • Download URL: cogflow-3.0.0b14.tar.gz
  • Upload date:
  • Size: 368.6 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/7.0.0 CPython/3.13.14

File hashes

Hashes for cogflow-3.0.0b14.tar.gz
Algorithm Hash digest
SHA256 6eb91d2f0b7502c8ce7202382a1c6646eabbe5357f07fb8adf131ac17812dd00
MD5 b6850a16143054ad7c49bbc30cc25272
BLAKE2b-256 07b50701946d10a4896a40ce856ebdac02d0ae3b41f89a0049fa7972d55d9693

See more details on using hashes here.

Provenance

The following attestation bundles were made for cogflow-3.0.0b14.tar.gz:

Publisher: release.yml on HIRO-MicroDataCenters-BV/cogflow

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

File details

Details for the file cogflow-3.0.0b14-py3-none-any.whl.

File metadata

  • Download URL: cogflow-3.0.0b14-py3-none-any.whl
  • Upload date:
  • Size: 421.9 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/7.0.0 CPython/3.13.14

File hashes

Hashes for cogflow-3.0.0b14-py3-none-any.whl
Algorithm Hash digest
SHA256 55feb29bc70068eebde0293374024d508f2f966f588c6320230cc43ab5ecfac8
MD5 3e15b815a98f2caa670b412249a54633
BLAKE2b-256 69dd457fda9a7ba59191f7c749248dd4933cd73a49fe97a15fdad84a4bd9b8e9

See more details on using hashes here.

Provenance

The following attestation bundles were made for cogflow-3.0.0b14-py3-none-any.whl:

Publisher: release.yml on HIRO-MicroDataCenters-BV/cogflow

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

3.0.0b14 This release

2 files

1.13.8

2 files

1.13.7

2 files

1.13.6

2 files

1.13.5

2 files

1.13.4

2 files

1.13.3

2 files

1.13.2

2 files

1.13.1

2 files

1.13.0

2 files

1.12.0

2 files

1.11.27

2 files

1.11.26

2 files

1.11.25

2 files

1.11.24

2 files

1.11.23

2 files

1.11.22

2 files

1.11.21

2 files

1.11.20

2 files

1.11.19

2 files

1.11.18

2 files

1.11.17

2 files

1.11.16

2 files

1.11.15

2 files

1.11.14

2 files

1.11.13

2 files

1.11.12

2 files

1.11.11

2 files

1.11.10

2 files

1.11.9

2 files

1.11.8

2 files

1.11.7

2 files

1.11.6

2 files

1.11.5

2 files

1.11.4

2 files

1.11.3

2 files

1.11.2

2 files

1.11.1

2 files

1.11.0

2 files

1.10.13

2 files

1.10.12

2 files

1.10.11

2 files

1.10.10

2 files

1.10.9

2 files

1.10.8

2 files

1.10.7

2 files

1.10.5

2 files

1.10.4

2 files

1.10.3.1

2 files

1.10.3

2 files

1.10.2

2 files

1.10.1

2 files

1.10.0

2 files

1.9.47

2 files

1.9.46

2 files

1.9.45

2 files

1.9.44

2 files

1.9.43

2 files

1.9.40

2 files

1.9.39

2 files

1.9.38

2 files

1.9.37

2 files

1.9.36

2 files

1.9.35

2 files

1.9.34

2 files

1.9.32

2 files

1.9.31

2 files

1.9.30

2 files

1.9.29

2 files

1.9.28

2 files

1.9.27

2 files

1.9.26

2 files

1.9.25

2 files

1.9.24

2 files

1.9.23

2 files

1.9.22

2 files

1.9.21

2 files

1.9.20

2 files

1.9.19

2 files

1.9.18

2 files

1.9.17

2 files

1.9.16

2 files

1.9.15

2 files

1.9.14

2 files

1.9.13

2 files

1.9.12

2 files

1.9.11

2 files

1.9.10

2 files

1.9.9

2 files

1.9.8

2 files

1.9.7

2 files

1.9.6

2 files

1.9.4

2 files

1.9.3

2 files

1.9.2

2 files

1.9.1

2 files

1.9.0

2 files

1.8.9

2 files

1.8.8

2 files

1.8.7

2 files

1.8.6

2 files

1.8.5

2 files

1.8.4

2 files

1.8.3

2 files

1.8.2

2 files

1.8.1

2 files

1.6.0

2 files

1.5.2

2 files

1.3.6

2 files

1.3.5

2 files

1.3.4

2 files

1.3.3

2 files

1.3.2

2 files

1.3.1

2 files

1.3.0

2 files

1.2.25

2 files

1.2.24

2 files

1.2.23

2 files

1.2.22

2 files

1.2.21

2 files

1.2.20

2 files

1.2.19

2 files

1.2.18

2 files

1.2.17

2 files

1.2.16

2 files

1.2.15

2 files

1.2.14

2 files

1.2.13

2 files

1.2.12

2 files

1.2.11

2 files

1.2.10

2 files

1.2.9

2 files

1.2.8

2 files

1.2.7

2 files

1.2.6

2 files

1.2.5

2 files

1.2.4

2 files

1.2.3

2 files

1.2.2

2 files

1.2.1

2 files

1.2

3 files

1.1

2 files

1.0

2 files

0.9

2 files

0.8

2 files

0.7

2 files

0.6

2 files

0.5

2 files

0.4

2 files

0.3

2 files

0.2

2 files

0.1.0

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