pydiverse.pipedag

Rules for working on ParquetTableStore and its metadata synchronization layer. Use when touching duckdb_parquet.py, sync_views, metadata_store, schema_prefix, or S3/GCS/MinIO integration.

Transaction model using __odd/__even schema slots. Use when working on init_stage, commit_stage, Schema, Stage, or transaction handling.

Table hook registration and materialization/retrieval for different data frameworks. Use when working on register_table, PandasTableHook, PolarsTableHook, SQLAlchemyTableHook, PyArrow, or View resolution.

Test instance configuration and pytest flag conventions. Use when running tests, adding new test instances, or debugging CI failures involving with_instances, skip_instances, conftest, or INSTANCE_MARKS.