|
|
|
@ -2,7 +2,7 @@
|
|
|
|
|
"""Tools for interacting with Spark SQL."""
|
|
|
|
|
from typing import Any, Dict, Optional
|
|
|
|
|
|
|
|
|
|
from langchain.pydantic_v1 import BaseModel, Extra, Field, root_validator
|
|
|
|
|
from langchain.pydantic_v1 import BaseModel, Field, root_validator
|
|
|
|
|
|
|
|
|
|
from langchain.schema.language_model import BaseLanguageModel
|
|
|
|
|
from langchain.callbacks.manager import (
|
|
|
|
@ -21,6 +21,9 @@ class BaseSparkSQLTool(BaseModel):
|
|
|
|
|
|
|
|
|
|
db: SparkSQL = Field(exclude=True)
|
|
|
|
|
|
|
|
|
|
class Config(BaseTool.Config):
|
|
|
|
|
pass
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class QuerySparkSQLTool(BaseSparkSQLTool, BaseTool):
|
|
|
|
|
"""Tool for querying a Spark SQL."""
|
|
|
|
|