rust-data-processing 0.2.2

Schema-first ingestion (CSV, JSON, Parquet, Excel) into an in-memory DataSet, plus Polars-backed pipelines, SQL, profiling, validation, and map/reduce-style processing.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

"""
Minimal Airflow DAG sketch (reference). Adjust imports for your Airflow version.
Replace bash_command with: python -c "import rust_data_processing as rdp; ..."
"""

from datetime import datetime

from airflow import DAG
from airflow.operators.bash import BashOperator

with DAG(
    dag_id="rust_data_processing_minimal",
    start_date=datetime(2026, 1, 1),
    schedule=None,
    catchup=False,
) as dag:
    BashOperator(
        task_id="noop_ok",
        bash_command='echo "Replace with rust-data-processing ingest/validate; exit 0"',
    )