GeezerVison is showing github.com — cel-python/cel_expr_python/py_cel_python_extension.cc at main · yarikoptic/cel-python

Expand file tree

py_cel_python_extension.cc

Copy path

More file actions

Latest commit

History

146 lines (129 loc) · 5.47 KB

py_cel_python_extension.cc

Copy path

File metadata and controls

146 lines (129 loc) · 5.47 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

// Licensed under the Apache License, Version 2.0 (the "License");

// you may not use this file except in compliance with the License.

// You may obtain a copy of the License at

// https://www.apache.org/licenses/LICENSE-2.0

// Unless required by applicable law or agreed to in writing, software

// distributed under the License is distributed on an "AS IS" BASIS,

// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

// See the License for the specific language governing permissions and

// limitations under the License.

#include "cel_expr_python/py_cel_python_extension.h"

#include <Python.h> // IWYU pragma: keep - Needed for PyObject

#include <memory>

#include <string>

#include <utility>

#include <vector>

#include "absl/status/status.h"

#include "checker/type_checker_builder.h"

#include "common/decl.h"

#include "common/function_descriptor.h"

#include "common/kind.h"

#include "common/type.h"

#include "compiler/compiler.h"

#include "runtime/runtime_builder.h"

#include "runtime/runtime_options.h"

#include "cel_expr_python/cel_extension.h"

#include "cel_expr_python/py_cel_function.h"

#include "cel_expr_python/py_cel_function_decl.h"

#include "cel_expr_python/py_cel_overload.h"

#include "cel_expr_python/py_cel_type.h"

#include "cel_expr_python/status_macros.h"

#include "google/protobuf/arena.h"

#include "google/protobuf/descriptor.h"

#include <pybind11/pybind11.h>

#include <pybind11/stl.h>

namespace cel_python {

namespace py = ::pybind11;

static const cel::FunctionDescriptorOptions kFunctionDescriptorOptions = {

.is_strict = true, .is_contextual = true};

void PyCelPythonExtension::DefinePythonBindings(py::module_& m) {

py::class_<CelExtension>(m, "CelExtensionBase")

.def(py::init<std::string>(), py::arg("name"));

py::class_<PyCelPythonExtension, CelExtension>(m, "CelExtension")

.def(py::init<std::string, std::vector<PyCelFunctionDecl>>(),

py::arg("name"), py::arg("functions"));

}

PyCelPythonExtension::PyCelPythonExtension(

std::string name, std::vector<PyCelFunctionDecl> functions)

: CelExtension(std::move(name)), functions_(std::move(functions)) {}

namespace {

absl::Status ConfigureChecker(cel::TypeCheckerBuilder& checker_builder,

const std::vector<PyCelFunctionDecl>& functions) {

google::protobuf::Arena* arena = checker_builder.arena();

const google::protobuf::DescriptorPool* descriptor_pool =

checker_builder.descriptor_pool();

for (const PyCelFunctionDecl& function : functions) {

cel::FunctionDecl function_decl;

function_decl.set_name(function.name());

for (const PyCelOverload& overload : function.overloads()) {

cel::OverloadDecl overload_decl;

overload_decl.set_id(overload.overload_id());

CEL_PYTHON_ASSIGN_OR_RETURN(

cel::Type cel_type, PyCelType::ToCelType(overload.return_type(),

arena, *descriptor_pool));

overload_decl.set_result(cel_type);

overload_decl.set_member(overload.is_member());

auto& mutable_args = overload_decl.mutable_args();

mutable_args.reserve(overload.parameters().size());

for (const auto& arg : overload.parameters()) {

CEL_PYTHON_ASSIGN_OR_RETURN(

cel::Type cel_type,

PyCelType::ToCelType(arg, arena, *descriptor_pool));

mutable_args.push_back(cel_type);

}

CEL_PYTHON_RETURN_IF_ERROR(

function_decl.AddOverload(std::move(overload_decl)));

}

CEL_PYTHON_RETURN_IF_ERROR(checker_builder.MergeFunction(function_decl));

}

return absl::OkStatus();

}

} // namespace

cel::CompilerLibrary PyCelPythonExtension::GetCompilerLibrary() {

// Capturing `this` is safe because it is guaranteed to outlive

// PyCelEnvInternal, which creates and destroys a transient CompilerBuilder -

// the only consumer of the CompilerLibrary.

return cel::CompilerLibrary(

name(),

/*configure_parser=*/nullptr,

/*configure_checker=*/

[this](cel::TypeCheckerBuilder& checker_builder) -> absl::Status {

return ConfigureChecker(checker_builder, functions_);

});

}

absl::Status PyCelPythonExtension::ConfigureRuntime(

cel::RuntimeBuilder& runtime_builder, const cel::RuntimeOptions& opts) {

for (const PyCelFunctionDecl& function : functions_) {

for (const PyCelOverload& overload : function.overloads()) {

std::vector<cel::Kind> types;

types.reserve(overload.parameters().size());

for (const PyCelType& arg : overload.parameters()) {

if (arg.GetKind() == cel::Kind::kDyn) {

// C++ runtime dispatcher historically uses kAny for wildcard type (

// not distinguishing between dyn and any)

types.push_back(cel::Kind::kAny);

} else {

types.push_back(arg.GetKind());

}

cel::FunctionDescriptor descriptor(function.name(), overload.is_member(),

types, kFunctionDescriptorOptions);

if (!overload.py_function().is_none()) {

CEL_PYTHON_RETURN_IF_ERROR(runtime_builder.function_registry().Register(

descriptor, std::make_unique<PyCelFunctionAdapter>(

function.name(), overload.return_type(),

overload.py_function())));

} else {

CEL_PYTHON_RETURN_IF_ERROR(

runtime_builder.function_registry().RegisterLazyFunction(

descriptor));

}

return absl::OkStatus();

}

} // namespace cel_python