| Name | Version | Summary | date |
| datacompose |
0.2.5.2 |
Copy-pasteable data transformation primitives for PySpark. Inspired by shadcn-svelte. |
2025-08-22 21:35:57 |
| dagster-kafka |
1.3.1 |
Enterprise-grade Kafka integration for Dagster with Confluent Connect, comprehensive serialization support, DLQ handling, and production monitoring |
2025-08-21 21:48:43 |
| xflow-py |
0.1.26 |
A modular ML framework for training and evaluation tasks |
2025-08-20 20:20:32 |
| slice-score |
1.0.1 |
Schema Lineage Composite Evaluation - A Python package for evaluating schema lineage extraction accuracy |
2025-08-17 00:29:58 |
| laktory |
0.8.7 |
An ETL and DataOps framework for building a lakehouse |
2025-08-15 02:29:31 |
| dg-sqlmesh |
1.8.1 |
Seamless integration between Dagster and SQLMesh for modern data engineering workflows |
2025-08-14 15:34:36 |
| sparkdq |
0.11.0 |
A declarative PySpark framework for row- and aggregate-level data quality validation. |
2025-08-09 16:03:40 |
| rushdb |
1.10.0 |
RushDB Python SDK |
2025-07-27 12:13:16 |
| scrapy-item-ingest |
0.1.2 |
Scrapy extension for database ingestion with job/spider tracking |
2025-07-22 13:34:03 |
| fast-dag |
0.2.0 |
A lightweight, high-performance Python library for building and executing DAG (Directed Acyclic Graph) and FSM (Finite State Machine) workflows |
2025-07-18 18:37:31 |
| fluid-pysdk |
1.0.4 |
Python SDK for fluid-cloudnative fluid to manage datasets |
2025-01-20 03:45:43 |
| steamstore-etl |
0.0.15 |
CLI for Steam Store Data Ingestion ETL Pipeline |
2024-08-29 05:53:55 |