Method to_engine

python/pathway/internals/dtype.py:514–515

(self)

        self.wrapped = wrapped

    def to_engine(self) -> PathwayType:
        return api.PathwayType.future(self.wrapped.to_engine())

    def is_value_compatible(self, arg):
        return arg is api.PENDING or self.wrapped.is_value_compatible(arg)