Function test_freeze_instance

python/pathway/tests/temporal/test_operators.py:240–273

()

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

    res = t._freeze(
        pw.this.t + 2,
        pw.this.t,
        instance_column=pw.this.a,
    )
    expected = pw.debug.table_from_markdown(
        """
        a |  t | __time__
        1 |  2 |     2
        1 |  3 |     2
        1 |  5 |     6
        1 | 15 |     8
        2 |  4 |     2
        2 |  8 |     4
        3 |  1 |     6
    """
    )
    assert_stream_equality_wo_index(res, expected)


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