Skip to main content

CogFlow

Cogflow module sets up a pipeline for handling datasets and machine learning models using multiple plugins. It includes functions for creating, registering, evaluating, and serving models, as well as managing datasets.

Key components include:

Mlflow Plugin: For model tracking, logging, and evaluation. Kubeflow Plugin: For pipeline management and serving models. Dataset Plugin: For dataset registration and management. Model Plugin: For saving model details. Configurations: Constants for configuration like tracking URIs, database credentials, etc.

Key Functions:

Model Management

register_model: Register a new model. log_model: Log a model. load_model: Load a model. delete_registered_model: Delete a registered model. create_registered_model: Create a new registered model. create_model_version: Create a new version of a registered model.

Run Management

start_run: Start a new. end_run: End the current. log_param: Log a parameter to the current run. log_metric: Log a metric to the current run.

Evaluation and Autologging

evaluate: Evaluate a model. autolog: Enable automatic logging of parameters, metrics, and models.

Search and Query

search_registered_models: Search for registered models. search_model_versions: Search for model versions. get_model_latest_version: Get the latest version of a registered model. get_artifact_uri: Get the artifact URI of the current or specified run.

Dataset Management

link_model_to_dataset: Link a model to a dataset. save_dataset_details: Save dataset details. save_model_details_to_db: Save model details to the database.

Pipeline and Component Management

pipeline: Create a new Kubeflow pipeline. create_component_from_func: Create a Kubeflow component from a function. client: Get the Kubeflow client. load_component_from_url: Load a Kubeflow component from a URL.

Model Serving

serve_model_v1: Serve a model using Kubeflow V1. serve_model_v2: Serve a model using Kubeflow V2. get_model_url: Get the URL of a served model. delete_served_model: Delete a served model.

MinIO Operations

create_minio_client: Create a MinIO client. query_endpoint_and_download_file: Query an endpoint and download a file from MinIO. save_to_minio: Save file content to MinIO. delete_from_minio: Delete an object from MinIO.

Dataset Registration

register_dataset: Register a dataset.

Getting Started

To begin, import cogflow from the CogFlow module:

import cogflow

Explore the Capabilities of cogflow

  • List Attributes and Methods: Understand the cogflow module better with:

    print(dir(cogflow))
    
  • Get Documentation: For a comprehensive guide on the cogflow, use:

    help(cogflow)
    

Environment Variables

To maximize the functionality of CogFlow, set the following environment variables:

  • Mlflow Configuration:

    • MLFLOW_TRACKING_URI: The URI of the Mlflow tracking server.
    • MLFLOW_S3_ENDPOINT_URL: The endpoint URL for the AWS S3 service.
    • ACCESS_KEY_ID: The access key ID for AWS S3 authentication.
    • SECRET_ACCESS_KEY: The secret access key for AWS S3 authentication.
  • Machine Learning Database:

    • ML_DB_USERNAME: Username for connecting to the machine learning database.
    • ML_DB_PASSWORD: Password for connecting to the machine learning database.
    • ML_DB_HOST: Host address for the machine learning database.
    • ML_DB_PORT: Port number for the machine learning database.
    • ML_DB_NAME: Name of the machine learning database.
  • CogFlow Database:

    • COGFLOW_DB_USERNAME: Username for connecting to the CogFlow database.
    • COGFLOW_DB_PASSWORD: Password for connecting to the CogFlow database.
    • COGFLOW_DB_HOST: Host address for the CogFlow database.
    • COGFLOW_DB_PORT: Port number for the CogFlow database.
    • COGFLOW_DB_NAME: Name of the CogFlow database.
  • MinIO Configuration:

    • MINIO_ENDPOINT_URL: The endpoint URL for the MinIO service.
    • MINIO_ACCESS_KEY: The access key for MinIO authentication.
    • MINIO_SECRET_ACCESS_KEY: The secret access key for MinIO authentication.

By setting the environment variables correctly, you can fully utilize the features and functionalities of the CogFlow framework for your cognitive and machine learning tasks.

Metadata

Release files for cogflow 1.13.8

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for cogflow 1.13.8
File Size Uploaded Provenance Actions
cogflow-1.13.8.tar.gz 101.6 kB Without provenance Details for cogflow-1.13.8.tar.gz

Built distribution (wheel)

Table of built distributions (wheels) for cogflow 1.13.8
File Interpreter ABI Platform Actions
cogflow-1.13.8-py3-none-any.whl Python 3 none any Details for cogflow-1.13.8-py3-none-any.whl

Total release size: 212.6 kB

Release files / cogflow-1.13.8.tar.gz

Download URL cogflow-1.13.8.tar.gz
Size 101.6 kB
Tags Source
SHA-256 checksum
How to use checksums
5a02bb9755ae9818a4fd7be5863aeed17805239ec1249f7d99bc7ec7e739e7ee
BLAKE2b-256 checksum
How to use checksums
698dc0ccb05fabb5100f0b91709b83462f6b7dbaaaf85dad0f2d07e9939448c4
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
No
Uploaded via twine/6.1.0 CPython/3.9.2rc1

Release files / cogflow-1.13.8-py3-none-any.whl

Download URL cogflow-1.13.8-py3-none-any.whl
Size 111.0 kB
Tags Python 3
SHA-256 checksum
How to use checksums
05c91c1f30551e3fcb740c7e3e62982eedd846697cd332c08bd5c58687fd2309
BLAKE2b-256 checksum
How to use checksums
813daf9dfe108956169f676a33741546d7e7caaf49238d84234a741395ee823b
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
No
Uploaded via twine/6.1.0 CPython/3.9.2rc1

Security for cogflow 1.13.8

Provenance

Provenance describes where a file came from. On PyPI, provenance is shared via attestations, which provide a verifiable record of the build or publishing details. View details, limitations and caveats.

No provenance found

None of the files in this release were uploaded with provenance metadata.

A note on package security

PyPI is a repository for distributing packages, not a service for auditing them. While third-party security researchers and our staff do their best to detect and remove malicious packages, PyPI cannot guarantee the quality, security or suitability of any given package.

To learn more about protecting yourself from malicious actors, visit our package security documentation.

Release history Release notifications | RSS feed

This release

1.13.8 This release

2 release files No provenance

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