def METHOD_NAME(task_runner, saved_search_owner_id_field):
    _, tid1 = get_watermark("tombstone", saved_search_owner_id_field)
    # TODO: Add another test to validate the tid is unique per field
    _, tid2 = get_watermark("row", saved_search_owner_id_field)
    assert tid1
    assert tid2
    assert tid1 != tid2
    set_watermark("tombstone", saved_search_owner_id_field, 5, tid1)
    wm, new_tid1 = get_watermark("tombstone", saved_search_owner_id_field)
    assert new_tid1 != tid1
    assert wm == 5
    assert get_watermark("tombstone", saved_search_owner_id_field) == (wm, new_tid1)