pip install dagster dagster-webserver pandas scikit-learn

cat > /tmp/dagster_demo.py << 'EOF'
import dagster as dg
import pandas as pd

@dg.asset
def sample_data() -> pd.DataFrame:
    return pd.DataFrame({"x": [1,2,3,4,5], "y": [2,4,6,8,10]})

@dg.asset
def summarized(sample_data: pd.DataFrame) -> pd.DataFrame:
    return sample_data.describe()

defs = dg.Definitions(assets=[sample_data, summarized])
EOF

dagster asset list -f /tmp/dagster_demo.py
