Function _sample_label_view

sdk/python/tests/unit/test_label_view.py:19–47

()

def _sample_label_view() -> LabelView:
    interaction = Entity(
        name="interaction",
        join_keys=["interaction_id"],
        value_type=ValueType.STRING,
    )
    label_push = PushSource(
        name="label_push",
        batch_source=FileSource(path="labels.parquet", timestamp_field="ts"),
    )
    return LabelView(
        name="interaction_labels",
        source=label_push,
        entities=[interaction],
        schema=[
            Field(name="interaction_id", dtype=String),
            Field(name="reward_label", dtype=String),
            Field(name="safety_score", dtype=Float32),
            Field(name="labeler", dtype=String),
        ],
        labeler_field="labeler",
        conflict_policy=ConflictPolicy.LAST_WRITE_WINS,
        reference_feature_view="interaction_history",
        ttl=timedelta(days=90),
        online=True,
        description="Mutable reward labels",
        tags={"team": "safety"},
        owner="safety@example.com",
    )


class TestLabelViewCreation: