Function test_tuple_reducer_consistency

python/pathway/tests/test_common.py:5920–5958

()

def test_tuple_reducer_consistency():
    left = T(
        """
    pet  |  owner  | age
    dog  | Bob     | 10
    cat  | Alice   | 9
    cat  | Alice   | 8
    dog  | Bob     | 7
    foo  | Charlie | 6
    """
    )

    left_res = left.reduce(
        pet=pw.reducers.tuple(left.pet),
        owner=pw.reducers.tuple(left.owner),
        age=pw.reducers.tuple(left.age),
    )

    t2 = left_res.select(
        pet=pw.this.pet.get(3), owner=pw.this.owner.get(3), age=pw.this.age.get(3)
    )
    print(t2.schema)

    joined = left.join(
        t2,
        left.pet == t2.pet,
        left.owner == t2.owner,
        left.age == t2.age,
    ).reduce(cnt=pw.reducers.count())

    assert_table_equality_wo_index(
        joined,
        T(
            """
            cnt
            1
            """
        ),
    )


@pytest.mark.parametrize(