dqm-ml-job 2.0.0rc1

Python library designed provide pipelining tools dqm-ml library to compute data quality metrics for Machine Learning

DQM-ML Job

Orchestration engine for DQM-ML V2. Handles data loading, processing, and output writing.

Installation

pip install dqm-ml-job

Note: dqm-ml-job handles data loading and orchestration. To compute metrics, you also need at least one of: dqm-ml-core, dqm-ml-images, or dqm-ml-pytorch (see Dependencies below).

Quick Start

Using Python

from dqm_ml_job.cli import execute

# Execute a data quality job from a YAML config
execute(["-p", "config.yaml"])

Using Python Module

python -m dqm_ml_job.cli -p config.yaml

Example config.yaml:

dataloaders:
  my_data:
    type: parquet
    path: data/train.parquet

metrics_processor:
  completeness:
    type: completeness
    input_columns: [col_a, col_b]

Dependencies

DQM-ML is modular — dqm-ml-job provides the orchestration, but you need additional packages to compute actual metrics:

# For Completeness and Representativeness
pip install dqm-ml-job dqm-ml-core

# For Visual Features
pip install dqm-ml-job dqm-ml-images

# For Domain Gap
pip install dqm-ml-job dqm-ml-pytorch

# All metrics
pip install dqm-ml-job dqm-ml-core dqm-ml-images dqm-ml-pytorch

Key Components

DatasetPipeline

The main orchestrator that:

• Loads the configuration
• Discovers plugins via entry points
• Executes the streaming loop
• Manages memory and I/O efficiency

Protocols

Protocol	Description
DataLoader	Factory for creating data selections (e.g., Parquet, CSV loaders)
DataSelection	Represents a specific subset of data and provides an iterator over batches
OutputWriter	Persists computed features or metrics to disk

Built-in Loaders

Loader	Description
parquet	Optimized loading using PyArrow
csv	Flexible loading using Pandas

See Also

• Configuration Guide
• Architecture Documentation