Function test_buffer_instance

python/pathway/tests/temporal/test_operators.py:130–165

()

def test_buffer_instance():
    t = pw.debug.table_from_markdown(
        """
        a |  t | __time__
        1 |  2 |     2
        1 |  3 |     2
        1 |  5 |     4
        1 | 15 |     8
        1 |  7 |    10
        2 |  4 |     2
        2 |  8 |     4
        2 |  9 |     8
        3 |  1 |     6
    """
    )

    res = t._buffer(
        pw.this.t + 2,
        pw.this.t,
        instance_column=pw.this.a,
    )
    expected = pw.debug.table_from_markdown(
        """
        a |  t | __time__
        1 |  2 |     4
        1 |  3 |     4
        1 |  5 |     8
        1 | 15 |   18446744073709551614
        1 |  7 |    10
        2 |  4 |     4
        2 |  8 |   18446744073709551614
        2 |  9 |   18446744073709551614
        3 |  1 |   18446744073709551614
    """
    )
    assert_stream_equality_wo_index(res, expected)


@pytest.mark.parametrize("public", [True, False])