Function ProcessArrowArrayStream

catboost/python-package/catboost/arrow.cpp:362–380

    template <class F>
    void ProcessArrowArrayStream(
        PyObject* capsule,
        F&& callback
    ) {
        try {
            auto* stream = (ArrowArrayStream*)PyCapsule_GetPointer(capsule, "arrow_array_stream");
            if (!stream) {
                return;
            }

            auto array  = MakeIntrusive<TArrowArrayHolder>(stream);
            auto schema = MakeIntrusive<TArrowSchemaHolder>(stream);

            callback(std::move(schema), std::move(array));

        } catch (...) {
            ProcessException();
        }
    }

    void AsyncAddArrowNumColumn(
        ui32 flatFeatureIdx,