fixes and refactory
This commit is contained in:
parent
8f31291d97
commit
6d92b38167
2 changed files with 3 additions and 3 deletions
|
|
@ -42,10 +42,10 @@ class AstraVectorize(Component):
|
||||||
),
|
),
|
||||||
]
|
]
|
||||||
outputs = [
|
outputs = [
|
||||||
Output(display_name="Vectorize", name="config", method="build", types=["dict"]),
|
Output(display_name="Vectorize", name="config", method="build_options", types=["dict"]),
|
||||||
]
|
]
|
||||||
|
|
||||||
def build(self) -> dict[str, Any]:
|
def build_options(self) -> dict[str, Any]:
|
||||||
return {
|
return {
|
||||||
"collection_vector_service_options": {
|
"collection_vector_service_options": {
|
||||||
"provider": self.provider,
|
"provider": self.provider,
|
||||||
|
|
|
||||||
|
|
@ -29,7 +29,7 @@ class TelemetryService(Service):
|
||||||
super().__init__()
|
super().__init__()
|
||||||
self.settings_service = settings_service
|
self.settings_service = settings_service
|
||||||
self.base_url = settings_service.settings.telemetry_base_url
|
self.base_url = settings_service.settings.telemetry_base_url
|
||||||
self.telemetry_queue = asyncio.Queue()
|
self.telemetry_queue: asyncio.Queue = asyncio.Queue()
|
||||||
self.client = httpx.AsyncClient(timeout=None)
|
self.client = httpx.AsyncClient(timeout=None)
|
||||||
self.running = False
|
self.running = False
|
||||||
self.package = get_version_info()["package"]
|
self.package = get_version_info()["package"]
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue