def METHOD_NAME(storage_connection_str, table_name):
    fully_qualified_namespace = "test_namespace"
    eventhub_name = "eventhub"
    consumer_group = "$default"
    ownership_cnt = 8
    checkpoint_store = TableCheckpointStore.from_connection_string(
        storage_connection_str, table_name
    )
    ownership_list = checkpoint_store.list_ownership(
        fully_qualified_namespace, eventhub_name, consumer_group
    )
    assert len(ownership_list) == 0
    ownership_list = []
    for i in range(ownership_cnt):
        ownership = _create_ownership(str(i), "owner_id", None, None)
        ownership_list.append(ownership)
    result_ownership_list = checkpoint_store.claim_ownership(ownership_list)
    assert ownership_list != result_ownership_list
    assert len(result_ownership_list) == len(ownership_list)
    for i in range(len(ownership_list)):
        assert ownership_list[i]["etag"] != result_ownership_list[i]["etag"]
        assert (
            ownership_list[i]["last_modified_time"]
            != result_ownership_list[i]["last_modified_time"]
        )
    ownership_list = checkpoint_store.list_ownership(
        fully_qualified_namespace, eventhub_name, consumer_group
    )
    assert len(ownership_list) == ownership_cnt
    assert len(ownership_list) == len(result_ownership_list)
    for i in range(len(result_ownership_list)):
        assert ownership_list[i]["etag"] == result_ownership_list[i]["etag"]
        assert (
            ownership_list[i]["last_modified_time"]
            == result_ownership_list[i]["last_modified_time"]
        )