fix:chromadb version

This commit is contained in:
aries_ckt
2023-09-27 12:03:05 +08:00
parent 6843fc7376
commit 1d3ea2acd5
2 changed files with 4 additions and 4 deletions

View File

@@ -1,6 +1,4 @@
from typing import Optional, Any
from pyspark.sql import SparkSession, DataFrame
from sqlalchemy import text
from pilot.connections.base import BaseConnect
@@ -19,6 +17,7 @@ class SparkConnect(BaseConnect):
driver: str = "spark"
"""db dialect"""
dialect: str = "sparksql"
from pyspark.sql import SparkSession, DataFrame
def __init__(
self,
@@ -30,6 +29,7 @@ class SparkConnect(BaseConnect):
"""Initialize the Spark DataFrame from Datasource path
return: Spark DataFrame
"""
from pyspark.sql import SparkSession
self.spark_session = (
spark_session or SparkSession.builder.appName("dbgpt_spark").getOrCreate()
)