Function test_forget_instance

python/pathway/tests/temporal/test_operators.py:9–48

()

def test_forget_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._forget(
        pw.this.t + 2,
        pw.this.t,
        mark_forgetting_records=False,
        instance_column=pw.this.a,
    )
    expected = pw.debug.table_from_markdown(
        """
        a |  t | __time__ | __diff__
        1 |  2 |     2    |     1
        1 |  3 |     2    |     1
        1 |  5 |     4    |     1
        1 |  2 |     6    |    -1
        1 |  3 |     6    |    -1
        1 | 15 |     8    |     1
        1 |  5 |    10    |    -1
        2 |  4 |     2    |     1
        2 |  8 |     4    |     1
        2 |  4 |     6    |    -1
        2 |  9 |     8    |     1
        3 |  1 |     6    |     1
    """
    )
    assert_stream_equality_wo_index(res, expected)


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