summaryrefslogtreecommitdiffstats
path: root/yql/essentials/udfs/common/python/bindings/py_tuple_ut.cpp
blob: 905a5ec382a0fd2abd1b6e8176121b319bce39c8 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
#include "py_test_engine.h"

#include <library/cpp/testing/unittest/registar.h>

using namespace NPython;

Y_UNIT_TEST_SUITE(TPyTupleTest) {
Y_UNIT_TEST(FromPyEmptyTuple) {
    TPythonTestEngine engine;
    engine.ToMiniKQL<NUdf::TTuple<>>(
        "def Test(): return ()",
        [](const NUdf::TUnboxedValuePod&) {});
}

Y_UNIT_TEST(FromPyList) {
    TPythonTestEngine engine;
    engine.ToMiniKQL<NUdf::TTuple<int, int, int>>(
        "def Test(): return [1, 2, 3]",
        [](const NUdf::TUnboxedValuePod& value) {
            UNIT_ASSERT(value);
            UNIT_ASSERT(value.IsBoxed());
            UNIT_ASSERT_EQUAL(value.GetElement(0).Get<int>(), 1);
            UNIT_ASSERT_EQUAL(value.GetElement(1).Get<int>(), 2);
            UNIT_ASSERT_EQUAL(value.GetElement(2).Get<int>(), 3);
        });
}

Y_UNIT_TEST(FromPyIter) {
    TPythonTestEngine engine;
    engine.ToMiniKQL<NUdf::TTuple<int, int, int>>(
        "def Test(): return iter({1, 2, 3})",
        [](const NUdf::TUnboxedValuePod& value) {
            UNIT_ASSERT(value);
            UNIT_ASSERT(value.IsBoxed());
            UNIT_ASSERT_EQUAL(value.GetElement(0).Get<int>(), 1);
            UNIT_ASSERT_EQUAL(value.GetElement(1).Get<int>(), 2);
            UNIT_ASSERT_EQUAL(value.GetElement(2).Get<int>(), 3);
        });
}

Y_UNIT_TEST(FromPyTuple) {
    TPythonTestEngine engine;
    engine.ToMiniKQL<NUdf::TTuple<int, double, char*>>(
        "def Test(): return (1, float(2.3), '4')",
        [](const NUdf::TUnboxedValuePod& value) {
            UNIT_ASSERT(value);
            UNIT_ASSERT(value.IsBoxed());
            UNIT_ASSERT_EQUAL(value.GetElement(0).Get<int>(), 1);
            auto second = value.GetElement(1);
            UNIT_ASSERT_DOUBLES_EQUAL(second.Get<double>(), 2.3, 0.0001);
            const auto third = value.GetElement(2);
            UNIT_ASSERT_EQUAL(third.AsStringRef(), "4");
        });
}

Y_UNIT_TEST(FromPyTupleInTuple) {
    TPythonTestEngine engine;
    engine.ToMiniKQL<NUdf::TTuple<ui32, NUdf::TTuple<ui8, float>, char*>>(
        "def Test(): return (1, (2, float(3.4)), '5')",
        [](const NUdf::TUnboxedValuePod& value) {
            UNIT_ASSERT(value);
            UNIT_ASSERT(value.IsBoxed());
            UNIT_ASSERT_EQUAL(value.GetElement(0).Get<ui32>(), 1);

            auto second = value.GetElement(1);
            UNIT_ASSERT(second);
            UNIT_ASSERT(second.IsBoxed());
            UNIT_ASSERT_EQUAL(second.GetElement(0).Get<ui8>(), 2);
            UNIT_ASSERT_DOUBLES_EQUAL(
                second.GetElement(1).Get<float>(), 3.4, 0.0001);

            const auto third = value.GetElement(2);
            UNIT_ASSERT_EQUAL(third.AsStringRef(), "5");
        });
}

Y_UNIT_TEST(ToPyEmptyTuple) {
    TPythonTestEngine engine;
    engine.ToPython<NUdf::TTuple<>>(
        [](const TType* type, const NUdf::IValueBuilder& vb) {
            NUdf::TUnboxedValue* items = nullptr;
            return vb.NewArray(static_cast<const TTupleType*>(type)->GetElementsCount(), items);
        },
        "def Test(value):\n"
        "    assert isinstance(value, tuple)\n"
        "    assert len(value) == 0\n"
        "    assert value == ()\n");
}

Y_UNIT_TEST(ToPyTuple) {
    TPythonTestEngine engine;
    engine.ToPython<NUdf::TTuple<NUdf::TUtf8, ui64, ui8, float>>(
        [](const TType* type, const NUdf::IValueBuilder& vb) {
            NUdf::TUnboxedValue* items = nullptr;
            auto tuple = vb.NewArray(static_cast<const TTupleType*>(type)->GetElementsCount(), items);
            items[0] = vb.NewString("111");
            items[1] = NUdf::TUnboxedValuePod((ui64)2);
            items[2] = NUdf::TUnboxedValuePod((ui8)3);
            items[3] = NUdf::TUnboxedValuePod((float)4.5);
            return tuple;
        },
        "def Test(value):\n"
        "    assert isinstance(value, tuple)\n"
        "    assert len(value) == 4\n"
        "    assert value == ('111', 2, 3, 4.5)\n");
}
} // Y_UNIT_TEST_SUITE(TPyTupleTest)