File tree Expand file tree Collapse file tree
templates/function/payload Expand file tree Collapse file tree Original file line number Diff line number Diff line change 3737# This lets all readers and writers to be findable via config
3838from datacustomcode .io import * # noqa: F403
3939from datacustomcode .io .base import BaseDataAccessLayer
40- from datacustomcode .io .reader .base import BaseDataCloudReader
41- from datacustomcode .io .writer .base import BaseDataCloudWriter
4240from datacustomcode .spark .base import BaseSparkSessionProvider
4341
4442if TYPE_CHECKING :
4543 from pyspark .sql import SparkSession
44+ from datacustomcode .io .reader .base import BaseDataCloudReader
45+ from datacustomcode .io .writer .base import BaseDataCloudWriter
4646
4747
4848_T = TypeVar ("_T" , bound = "BaseDataAccessLayer" )
@@ -82,8 +82,8 @@ def to_object(self) -> _P:
8282
8383
8484class ClientConfig (BaseConfig ):
85- reader_config : Union [AccessLayerObjectConfig [BaseDataCloudReader ], None ] = None
86- writer_config : Union [AccessLayerObjectConfig [BaseDataCloudWriter ], None ] = None
85+ reader_config : Union [AccessLayerObjectConfig [" BaseDataCloudReader" ], None ] = None
86+ writer_config : Union [AccessLayerObjectConfig [" BaseDataCloudWriter" ], None ] = None
8787 spark_config : Union [SparkConfig , None ] = None
8888 spark_provider_config : Union [
8989 SparkProviderConfig [BaseSparkSessionProvider ], None
Original file line number Diff line number Diff line change 1919 Optional ,
2020)
2121
22- import requests
2322from loguru import logger
23+ import requests
2424
2525from datacustomcode .einstein_platform_client import EinsteinPlatformClient
2626from datacustomcode .llm_gateway .base import LLMGateway
@@ -44,8 +44,7 @@ def __init__(
4444
4545 def generate_text (self , request : GenerateTextRequest ) -> GenerateTextResponse :
4646 api_url = (
47- f"{ self .EINSTEIN_PLATFORM_URL } /models/"
48- f"{ request .model_name } /generations"
47+ f"{ self .EINSTEIN_PLATFORM_URL } /models/{ request .model_name } /generations"
4948 )
5049
5150 payload : Dict [str , Any ] = {"prompt" : request .prompt }
Original file line number Diff line number Diff line change @@ -80,8 +80,6 @@ def generate_text(runtime: Runtime):
8080 print (llm_response .error_code )
8181
8282
83-
84-
8583def function (request : dict , runtime : Runtime ) -> dict :
8684 logger .info ("Inside Function" )
8785 logger .info (request )
You can’t perform that action at this time.
0 commit comments