mirror of
https://github.com/QuivrHQ/quivr.git
synced 2024-12-13 19:23:54 +03:00
Stan Girard
GitHub
parent
ce751d2bd7
commit
8046741443
@ -64,13 +64,6 @@ BACKEND_URL=http://localhost:5050
|
||||
EMBEDDING_DIM=1536
|
||||
DEACTIVATE_STRIPE=true
|
||||
|
||||
|
||||
# PARSEABLE LOGGING
|
||||
USE_PARSEABLE=False
|
||||
PARSEABLE_STREAM_NAME=quivr-api
|
||||
PARSEABLE_URL=<change-me>
|
||||
PARSEABLE_AUTH=<change-me>
|
||||
|
||||
#RESEND
|
||||
RESEND_API_KEY=<change-me>
|
||||
RESEND_EMAIL_ADDRESS=onboarding@resend.dev
|
||||
|
||||
2
.gitignore
vendored
2
.gitignore
vendored
@ -80,7 +80,7 @@ paulgraham.py
|
||||
.env_test
|
||||
supabase/seed-airwallex.sql
|
||||
airwallexpayouts.py
|
||||
**/application.log*
|
||||
application.log
|
||||
backend/celerybeat-schedule.db
|
||||
|
||||
backend/application.log.*
|
||||
|
||||
@ -1,240 +1,45 @@
|
||||
import logging
|
||||
import os
|
||||
import queue
|
||||
import sys
|
||||
import threading
|
||||
from logging.handlers import RotatingFileHandler
|
||||
from typing import List
|
||||
|
||||
import orjson
|
||||
import requests
|
||||
import structlog
|
||||
|
||||
from quivr_api.models.settings import parseable_settings
|
||||
|
||||
# Thread-safe queue for log messages
|
||||
log_queue = queue.Queue()
|
||||
stop_log_queue = threading.Event()
|
||||
from colorlog import (
|
||||
ColoredFormatter,
|
||||
)
|
||||
|
||||
|
||||
class ParseableLogHandler(logging.Handler):
|
||||
def __init__(
|
||||
self,
|
||||
base_parseable_url: str,
|
||||
auth_token: str,
|
||||
stream_name: str,
|
||||
batch_size: int = 10,
|
||||
flush_interval: float = 1,
|
||||
):
|
||||
super().__init__()
|
||||
self.base_url = base_parseable_url
|
||||
self.stream_name = stream_name
|
||||
self.url = self.base_url + self.stream_name
|
||||
self.batch_size = batch_size
|
||||
self.flush_interval = flush_interval
|
||||
self._worker_thread = threading.Thread(target=self._process_log_queue)
|
||||
self._worker_thread.daemon = True
|
||||
self._worker_thread.start()
|
||||
self.headers = {
|
||||
"Authorization": f"Basic {auth_token}", # base64 encoding user:mdp
|
||||
"Content-Type": "application/json",
|
||||
}
|
||||
def get_logger(logger_name, log_file="application.log"):
|
||||
log_level = os.getenv("LOG_LEVEL", "WARNING").upper()
|
||||
logger = logging.getLogger(logger_name)
|
||||
logger.setLevel(log_level)
|
||||
logger.propagate = False # Prevent log propagation to avoid double logging
|
||||
|
||||
def emit(self, record: logging.LogRecord):
|
||||
# FIXME (@AmineDiro): This ping-pong of serialization/deserialization is a limitation of logging formatter
|
||||
# The formatter should return a 'str' for the logger to print
|
||||
if isinstance(record.msg, str):
|
||||
return
|
||||
elif isinstance(record.msg, dict):
|
||||
logger_name = record.msg.get("logger", None)
|
||||
if logger_name and (
|
||||
logger_name.startswith("quivr_api.access")
|
||||
or logger_name.startswith("quivr_api.error")
|
||||
):
|
||||
url = record.msg.get("url", None)
|
||||
# Filter on healthz
|
||||
if url and "healthz" not in url:
|
||||
fmt = orjson.loads(self.format(record))
|
||||
log_queue.put(fmt)
|
||||
else:
|
||||
return
|
||||
|
||||
def _process_log_queue(self):
|
||||
"""Background thread that processes the log queue and sends logs to Parseable."""
|
||||
logs_batch = []
|
||||
while not stop_log_queue.is_set():
|
||||
try:
|
||||
# Collect logs for batch processing
|
||||
log_data = log_queue.get(timeout=self.flush_interval)
|
||||
logs_batch.append(log_data)
|
||||
|
||||
# Send logs if batch size is reached
|
||||
if len(logs_batch) >= self.batch_size:
|
||||
self._send_logs_to_parseable(logs_batch)
|
||||
logs_batch.clear()
|
||||
|
||||
except queue.Empty:
|
||||
# If the queue is empty, send any remaining logs
|
||||
if logs_batch:
|
||||
self._send_logs_to_parseable(logs_batch)
|
||||
logs_batch.clear()
|
||||
|
||||
def _send_logs_to_parseable(self, logs: List[str]):
|
||||
payload = orjson.dumps(logs)
|
||||
try:
|
||||
response = requests.post(self.url, headers=self.headers, data=payload)
|
||||
if response.status_code != 200:
|
||||
print(f"Failed to send logs to Parseable server: {response.text}")
|
||||
except Exception as e:
|
||||
print(f"Error sending logs to Parseable: {e}")
|
||||
|
||||
def stop(self):
|
||||
"""Stop the background worker thread and process any remaining logs."""
|
||||
stop_log_queue.set()
|
||||
self._worker_thread.join()
|
||||
# Process remaining logs before shutting down
|
||||
remaining_logs = list(log_queue.queue)
|
||||
if remaining_logs:
|
||||
self._send_logs_to_parseable(remaining_logs)
|
||||
|
||||
|
||||
def extract_from_record(_, __, event_dict):
|
||||
"""
|
||||
Extract thread and process names and add them to the event dict.
|
||||
"""
|
||||
record = event_dict["_record"]
|
||||
event_dict["thread_name"] = record.threadName
|
||||
event_dict["process_name"] = record.processName
|
||||
return event_dict
|
||||
|
||||
|
||||
def drop_http_context(_, __, event_dict):
|
||||
"""
|
||||
Extract thread and process names and add them to the event dict.
|
||||
"""
|
||||
keys = ["msg", "logger", "level", "timestamp", "exc_info"]
|
||||
return {k: event_dict.get(k, None) for k in keys}
|
||||
|
||||
|
||||
def setup_logger(
|
||||
log_file="application.log", send_log_server: bool = parseable_settings.use_parseable
|
||||
):
|
||||
# Shared handlers
|
||||
shared_processors = [
|
||||
structlog.contextvars.merge_contextvars,
|
||||
structlog.stdlib.add_log_level,
|
||||
structlog.stdlib.add_logger_name,
|
||||
structlog.stdlib.PositionalArgumentsFormatter(),
|
||||
structlog.processors.TimeStamper(fmt="iso"),
|
||||
structlog.processors.StackInfoRenderer(),
|
||||
structlog.processors.UnicodeDecoder(),
|
||||
structlog.processors.EventRenamer("msg"),
|
||||
]
|
||||
structlog.configure(
|
||||
processors=shared_processors
|
||||
+ [
|
||||
structlog.stdlib.ProcessorFormatter.wrap_for_formatter,
|
||||
],
|
||||
# Use standard logging compatible logger
|
||||
logger_factory=structlog.stdlib.LoggerFactory(),
|
||||
wrapper_class=structlog.stdlib.BoundLogger,
|
||||
# Use Python's logging configuration
|
||||
cache_logger_on_first_use=True,
|
||||
)
|
||||
# Set Formatters
|
||||
plain_fmt = structlog.stdlib.ProcessorFormatter(
|
||||
foreign_pre_chain=shared_processors,
|
||||
processors=[
|
||||
extract_from_record,
|
||||
structlog.processors.format_exc_info,
|
||||
structlog.stdlib.ProcessorFormatter.remove_processors_meta,
|
||||
structlog.dev.ConsoleRenderer(
|
||||
colors=False, exception_formatter=structlog.dev.plain_traceback
|
||||
),
|
||||
],
|
||||
)
|
||||
color_fmt = structlog.stdlib.ProcessorFormatter(
|
||||
processors=[
|
||||
drop_http_context,
|
||||
structlog.dev.ConsoleRenderer(
|
||||
colors=True,
|
||||
exception_formatter=structlog.dev.RichTracebackFormatter(
|
||||
show_locals=False
|
||||
),
|
||||
),
|
||||
],
|
||||
foreign_pre_chain=shared_processors,
|
||||
)
|
||||
parseable_fmt = structlog.stdlib.ProcessorFormatter(
|
||||
processors=[
|
||||
# TODO: Which one gets us the better debug experience ?
|
||||
# structlog.processors.ExceptionRenderer(
|
||||
# exception_formatter=structlog.tracebacks.ExceptionDictTransformer(
|
||||
# show_locals=False
|
||||
# )
|
||||
# ),
|
||||
structlog.processors.format_exc_info,
|
||||
structlog.stdlib.ProcessorFormatter.remove_processors_meta,
|
||||
structlog.processors.JSONRenderer(),
|
||||
],
|
||||
foreign_pre_chain=shared_processors
|
||||
+ [
|
||||
structlog.processors.CallsiteParameterAdder(
|
||||
{
|
||||
structlog.processors.CallsiteParameter.FUNC_NAME,
|
||||
structlog.processors.CallsiteParameter.LINENO,
|
||||
}
|
||||
),
|
||||
],
|
||||
formatter = logging.Formatter(
|
||||
"[%(levelname)s] %(name)s [%(filename)s:%(lineno)d]: %(message)s"
|
||||
)
|
||||
|
||||
# Set handlers
|
||||
console_handler = logging.StreamHandler(sys.stdout)
|
||||
color_formatter = ColoredFormatter(
|
||||
"%(log_color)s[%(levelname)s]%(reset)s %(name)s [%(filename)s:%(lineno)d]: %(message)s",
|
||||
log_colors={
|
||||
"DEBUG": "cyan",
|
||||
"INFO": "green",
|
||||
"WARNING": "yellow",
|
||||
"ERROR": "red",
|
||||
"CRITICAL": "red,bg_white",
|
||||
},
|
||||
reset=True,
|
||||
style="%",
|
||||
)
|
||||
|
||||
console_handler = logging.StreamHandler()
|
||||
console_handler.setFormatter(color_formatter)
|
||||
|
||||
file_handler = RotatingFileHandler(
|
||||
log_file, maxBytes=5000000, backupCount=5
|
||||
) # 5MB file
|
||||
console_handler.setFormatter(color_fmt)
|
||||
file_handler.setFormatter(plain_fmt)
|
||||
handlers: list[logging.Handler] = [console_handler, file_handler]
|
||||
if (
|
||||
send_log_server
|
||||
and parseable_settings.parseable_url is not None
|
||||
and parseable_settings.parseable_auth is not None
|
||||
and parseable_settings.parseable_stream_name
|
||||
):
|
||||
parseable_handler = ParseableLogHandler(
|
||||
auth_token=parseable_settings.parseable_auth,
|
||||
base_parseable_url=parseable_settings.parseable_url,
|
||||
stream_name=parseable_settings.parseable_stream_name,
|
||||
)
|
||||
parseable_handler.setFormatter(parseable_fmt)
|
||||
handlers.append(parseable_handler)
|
||||
file_handler.setFormatter(formatter)
|
||||
|
||||
# Configure logger
|
||||
log_level = os.getenv("LOG_LEVEL", "INFO").upper()
|
||||
root_logger = logging.getLogger()
|
||||
root_logger.setLevel(log_level)
|
||||
root_logger.handlers = []
|
||||
for handler in handlers:
|
||||
root_logger.addHandler(handler)
|
||||
if not logger.handlers:
|
||||
logger.addHandler(console_handler)
|
||||
logger.addHandler(file_handler)
|
||||
|
||||
_clear_uvicorn_logger()
|
||||
|
||||
|
||||
def _clear_uvicorn_logger():
|
||||
for _log in ["uvicorn", "uvicorn.error"]:
|
||||
# Clear the log handlers for uvicorn loggers, and enable propagation
|
||||
# so the messages are caught by our root logger and formatted correctly
|
||||
# by structlog
|
||||
logging.getLogger(_log).handlers.clear()
|
||||
logging.getLogger(_log).propagate = True
|
||||
logging.getLogger("uvicorn.access").handlers.clear()
|
||||
logging.getLogger("uvicorn.access").propagate = False
|
||||
|
||||
|
||||
def get_logger(_name: str | None = None):
|
||||
assert structlog.is_configured()
|
||||
return structlog.get_logger()
|
||||
|
||||
|
||||
setup_logger()
|
||||
return logger
|
||||
|
||||
@ -4,15 +4,14 @@ import os
|
||||
import litellm
|
||||
import sentry_sdk
|
||||
from dotenv import load_dotenv # type: ignore
|
||||
from fastapi import FastAPI, Request
|
||||
from fastapi.responses import HTMLResponse
|
||||
from fastapi import FastAPI, HTTPException, Request
|
||||
from fastapi.responses import HTMLResponse, JSONResponse
|
||||
from pyinstrument import Profiler
|
||||
from sentry_sdk.integrations.fastapi import FastApiIntegration
|
||||
from sentry_sdk.integrations.starlette import StarletteIntegration
|
||||
|
||||
from quivr_api.logger import get_logger, stop_log_queue
|
||||
from quivr_api.logger import get_logger
|
||||
from quivr_api.middlewares.cors import add_cors_middleware
|
||||
from quivr_api.middlewares.logging_middleware import LoggingMiddleware
|
||||
from quivr_api.modules.analytics.controller.analytics_routes import analytics_router
|
||||
from quivr_api.modules.api_key.controller import api_key_router
|
||||
from quivr_api.modules.assistant.controller import assistant_router
|
||||
@ -28,6 +27,7 @@ from quivr_api.modules.upload.controller import upload_router
|
||||
from quivr_api.modules.user.controller import user_router
|
||||
from quivr_api.routes.crawl_routes import crawl_router
|
||||
from quivr_api.routes.subscription_routes import subscription_router
|
||||
from quivr_api.utils import handle_request_validation_error
|
||||
from quivr_api.utils.telemetry import maybe_send_telemetry
|
||||
|
||||
load_dotenv()
|
||||
@ -37,11 +37,11 @@ logging.basicConfig(level=logging.INFO)
|
||||
logging.getLogger("httpx").setLevel(logging.WARNING)
|
||||
logging.getLogger("LiteLLM").setLevel(logging.WARNING)
|
||||
logging.getLogger("litellm").setLevel(logging.WARNING)
|
||||
litellm.set_verbose = False # type: ignore
|
||||
get_logger("uvicorn")
|
||||
get_logger("uvicorn.access")
|
||||
get_logger("quivr_core")
|
||||
logger = get_logger("quivr-api")
|
||||
litellm.set_verbose = False # type: ignore
|
||||
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
def before_send(event, hint):
|
||||
@ -72,9 +72,6 @@ if sentry_dsn:
|
||||
app = FastAPI()
|
||||
add_cors_middleware(app)
|
||||
|
||||
app.add_middleware(LoggingMiddleware)
|
||||
|
||||
|
||||
app.include_router(brain_router)
|
||||
app.include_router(chat_router)
|
||||
app.include_router(crawl_router)
|
||||
@ -109,11 +106,16 @@ if PROFILING:
|
||||
return await call_next(request)
|
||||
|
||||
|
||||
@app.on_event("shutdown")
|
||||
def shutdown_event():
|
||||
stop_log_queue.set()
|
||||
@app.exception_handler(HTTPException)
|
||||
async def http_exception_handler(_, exc):
|
||||
return JSONResponse(
|
||||
status_code=exc.status_code,
|
||||
content={"detail": exc.detail},
|
||||
)
|
||||
|
||||
|
||||
handle_request_validation_error(app)
|
||||
|
||||
if os.getenv("TELEMETRY_ENABLED") == "true":
|
||||
logger.info("Telemetry enabled, we use telemetry to collect anonymous usage data.")
|
||||
logger.info(
|
||||
|
||||
@ -1,7 +1,6 @@
|
||||
import os
|
||||
from typing import Optional
|
||||
|
||||
import structlog
|
||||
from fastapi import Depends, HTTPException, Request
|
||||
from fastapi.security import HTTPAuthorizationCredentials, HTTPBearer
|
||||
|
||||
@ -14,8 +13,6 @@ from quivr_api.modules.user.entity.user_identity import UserIdentity
|
||||
|
||||
api_key_service = ApiKeyService()
|
||||
|
||||
logger = structlog.stdlib.get_logger("quivr_api.access")
|
||||
|
||||
|
||||
class AuthBearer(HTTPBearer):
|
||||
def __init__(self, auto_error: bool = True):
|
||||
@ -69,10 +66,5 @@ class AuthBearer(HTTPBearer):
|
||||
auth_bearer = AuthBearer()
|
||||
|
||||
|
||||
async def get_current_user(user: UserIdentity = Depends(auth_bearer)) -> UserIdentity:
|
||||
# Due to context switch in FastAPI executor we can't get this id back
|
||||
# We log it as an additional log so we can get information if exception was raised
|
||||
# https://www.structlog.org/en/stable/contextvars.html
|
||||
structlog.contextvars.bind_contextvars(client_id=user.id)
|
||||
logger.info("Authentication success")
|
||||
def get_current_user(user: UserIdentity = Depends(auth_bearer)) -> UserIdentity:
|
||||
return user
|
||||
|
||||
@ -1,94 +0,0 @@
|
||||
import subprocess
|
||||
import time
|
||||
import uuid
|
||||
|
||||
import structlog
|
||||
from fastapi import Request, Response, status
|
||||
from starlette.middleware.base import BaseHTTPMiddleware
|
||||
from structlog.contextvars import (
|
||||
bind_contextvars,
|
||||
clear_contextvars,
|
||||
)
|
||||
|
||||
logger = structlog.stdlib.get_logger("quivr_api.access")
|
||||
|
||||
git_sha = subprocess.check_output(["git", "rev-parse", "HEAD"]).strip().decode("utf-8")
|
||||
|
||||
|
||||
def clean_dict(d):
|
||||
"""Remove None values from a dictionary."""
|
||||
return {k: v for k, v in d.items() if v is not None}
|
||||
|
||||
|
||||
class LoggingMiddleware(BaseHTTPMiddleware):
|
||||
async def dispatch(self, request: Request, call_next):
|
||||
clear_contextvars()
|
||||
# Generate a unique request ID
|
||||
request_id = str(uuid.uuid4())
|
||||
|
||||
client_addr = (
|
||||
f"{request.client.host}:{request.client.port}" if request.client else None
|
||||
)
|
||||
url = request.url.path
|
||||
http_version = request.scope["http_version"]
|
||||
|
||||
bind_contextvars(
|
||||
**clean_dict(
|
||||
{
|
||||
"git_head": git_sha,
|
||||
"request_id": request_id,
|
||||
"method": request.method,
|
||||
"query_params": dict(request.query_params),
|
||||
"client_addr": client_addr,
|
||||
"request_user_agent": request.headers.get("user-agent"),
|
||||
"request_content_type": request.headers.get("content-type"),
|
||||
"url": url,
|
||||
"http_version": http_version,
|
||||
}
|
||||
)
|
||||
)
|
||||
|
||||
# Start time
|
||||
start_time = time.perf_counter()
|
||||
response = Response(status_code=status.HTTP_500_INTERNAL_SERVER_ERROR)
|
||||
try:
|
||||
# Process the request
|
||||
response: Response = await call_next(request)
|
||||
process_time = time.perf_counter() - start_time
|
||||
bind_contextvars(
|
||||
**clean_dict(
|
||||
{
|
||||
"response_content_type": response.headers.get("content-type"),
|
||||
"response_status": response.status_code,
|
||||
"response_headers": dict(response.headers),
|
||||
"timing_request_total_ms": round(process_time * 1e3, 3),
|
||||
}
|
||||
)
|
||||
)
|
||||
|
||||
logger.info(
|
||||
f"""{client_addr} - "{request.method} {url} HTTP/{http_version}" {response.status_code}""",
|
||||
)
|
||||
except Exception:
|
||||
process_time = time.perf_counter() - start_time
|
||||
bind_contextvars(
|
||||
**clean_dict(
|
||||
{
|
||||
"response_status": response.status_code,
|
||||
"timing_request_total_ms": round(process_time * 1000, 3),
|
||||
}
|
||||
)
|
||||
)
|
||||
structlog.stdlib.get_logger("quivr_api.error").exception(
|
||||
"Request failed with exception"
|
||||
)
|
||||
raise
|
||||
|
||||
finally:
|
||||
clear_contextvars()
|
||||
|
||||
# Add X-Request-ID to response headers
|
||||
response.headers["X-Request-ID"] = request_id
|
||||
response.headers["X-Process-Time"] = str(process_time)
|
||||
|
||||
return response
|
||||
@ -1,7 +1,15 @@
|
||||
from typing import Optional
|
||||
from uuid import UUID
|
||||
|
||||
from posthog import Posthog
|
||||
from pydantic_settings import BaseSettings, SettingsConfigDict
|
||||
from sqlalchemy import Engine
|
||||
|
||||
from quivr_api.logger import get_logger
|
||||
from quivr_api.models.databases.supabase.supabase import SupabaseDB
|
||||
from supabase.client import AsyncClient, Client
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
class BrainRateLimiting(BaseSettings):
|
||||
@ -114,7 +122,7 @@ class BrainSettings(BaseSettings):
|
||||
langfuse_secret_key: str | None = None
|
||||
pg_database_url: str
|
||||
pg_database_async_url: str
|
||||
embedding_dim: int = 1536
|
||||
embedding_dim: int
|
||||
|
||||
|
||||
class ResendSettings(BaseSettings):
|
||||
@ -126,13 +134,11 @@ class ResendSettings(BaseSettings):
|
||||
quivr_smtp_password: str = ""
|
||||
|
||||
|
||||
class ParseableSettings(BaseSettings):
|
||||
model_config = SettingsConfigDict(validate_default=False)
|
||||
use_parseable: bool = False
|
||||
parseable_url: str | None = None
|
||||
parseable_auth: str | None = None
|
||||
parseable_stream_name: str | None = None
|
||||
|
||||
# Global variables to store the Supabase client and database instances
|
||||
_supabase_client: Optional[Client] = None
|
||||
_supabase_async_client: Optional[AsyncClient] = None
|
||||
_supabase_db: Optional[SupabaseDB] = None
|
||||
_db_engine: Optional[Engine] = None
|
||||
_embedding_service = None
|
||||
|
||||
settings = BrainSettings() # type: ignore
|
||||
parseable_settings = ParseableSettings()
|
||||
|
||||
@ -4,21 +4,16 @@ from quivr_api.modules.dependencies import get_async_session
|
||||
from sqlmodel import text
|
||||
from sqlmodel.ext.asyncio.session import AsyncSession
|
||||
|
||||
logger = get_logger()
|
||||
logger = get_logger(__name__)
|
||||
|
||||
misc_router = APIRouter()
|
||||
|
||||
|
||||
@misc_router.get("/excp")
|
||||
async def excp():
|
||||
raise ValueError
|
||||
|
||||
|
||||
@misc_router.get("/")
|
||||
async def root():
|
||||
"""
|
||||
Root endpoint to check the status of the API.
|
||||
"""
|
||||
logger.info("this is a test", a=10)
|
||||
return {"status": "OK"}
|
||||
|
||||
|
||||
|
||||
@ -1,5 +0,0 @@
|
||||
from quivr_api.logger import get_logger
|
||||
|
||||
logger = get_logger("quivr-api")
|
||||
|
||||
logger.info("test")
|
||||
@ -0,0 +1,2 @@
|
||||
from .handle_request_validation_error import handle_request_validation_error
|
||||
from .parse_message_time import parse_message_time
|
||||
@ -0,0 +1,24 @@
|
||||
from fastapi import FastAPI, Request, status
|
||||
from fastapi.exceptions import RequestValidationError
|
||||
from fastapi.responses import JSONResponse
|
||||
|
||||
from quivr_api.logger import get_logger
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
def handle_request_validation_error(app: FastAPI):
|
||||
@app.exception_handler(RequestValidationError)
|
||||
async def validation_exception_handler(
|
||||
request: Request, exc: RequestValidationError
|
||||
):
|
||||
exc_str = f"{exc}".replace("\n", " ").replace(" ", " ")
|
||||
logger.error(request, exc_str)
|
||||
content = {
|
||||
"status_code": status.HTTP_422_UNPROCESSABLE_ENTITY,
|
||||
"message": exc_str,
|
||||
"data": None,
|
||||
}
|
||||
return JSONResponse(
|
||||
content=content, status_code=status.HTTP_422_UNPROCESSABLE_ENTITY
|
||||
)
|
||||
@ -10,10 +10,7 @@ authors = [
|
||||
]
|
||||
dependencies = [
|
||||
"packaging>=22.0",
|
||||
# Logging packages
|
||||
"structlog>=24.4.0",
|
||||
"python-json-logger>=2.0.7",
|
||||
"orjson>=3.10.7",
|
||||
"langchain-anthropic>=0.1.23",
|
||||
]
|
||||
readme = "README.md"
|
||||
requires-python = ">= 3.11"
|
||||
|
||||
@ -79,8 +79,6 @@ beautifulsoup4==4.12.3
|
||||
# via markdownify
|
||||
# via nbconvert
|
||||
# via unstructured
|
||||
better-exceptions==0.3.3
|
||||
# via quivr-monorepo
|
||||
bidict==0.23.1
|
||||
# via python-socketio
|
||||
billiard==4.2.0
|
||||
@ -146,7 +144,6 @@ cobble==0.1.4
|
||||
cohere==5.8.1
|
||||
# via langchain-cohere
|
||||
colorama==0.4.6
|
||||
# via better-exceptions
|
||||
# via click
|
||||
# via colorlog
|
||||
# via griffe
|
||||
@ -426,6 +423,7 @@ langchain==0.2.16
|
||||
# via quivr-diff-assistant
|
||||
langchain-anthropic==0.1.23
|
||||
# via quivr-core
|
||||
# via quivr-monorepo
|
||||
langchain-cohere==0.2.2
|
||||
# via quivr-api
|
||||
langchain-community==0.2.12
|
||||
@ -737,7 +735,6 @@ opentelemetry-semantic-conventions==0.48b0
|
||||
# via opentelemetry-sdk
|
||||
orjson==3.10.7
|
||||
# via langsmith
|
||||
# via quivr-monorepo
|
||||
packaging==23.2
|
||||
# via black
|
||||
# via chainlit
|
||||
@ -985,8 +982,6 @@ python-iso639==2024.4.27
|
||||
# via unstructured
|
||||
python-jose==3.3.0
|
||||
# via quivr-api
|
||||
python-json-logger==2.0.7
|
||||
# via quivr-monorepo
|
||||
python-magic==0.4.27
|
||||
# via quivr-diff-assistant
|
||||
# via unstructured
|
||||
@ -1140,8 +1135,6 @@ strenum==0.4.15
|
||||
# via postgrest
|
||||
striprtf==0.0.26
|
||||
# via llama-index-readers-file
|
||||
structlog==24.4.0
|
||||
# via quivr-monorepo
|
||||
supabase==2.7.2
|
||||
# via quivr-api
|
||||
supafunc==0.5.1
|
||||
|
||||
@ -74,8 +74,6 @@ beautifulsoup4==4.12.3
|
||||
# via markdownify
|
||||
# via nbconvert
|
||||
# via unstructured
|
||||
better-exceptions==0.3.3
|
||||
# via quivr-monorepo
|
||||
billiard==4.2.0
|
||||
# via celery
|
||||
bleach==6.1.0
|
||||
@ -128,7 +126,6 @@ cobble==0.1.4
|
||||
cohere==5.8.1
|
||||
# via langchain-cohere
|
||||
colorama==0.4.6
|
||||
# via better-exceptions
|
||||
# via click
|
||||
# via colorlog
|
||||
# via griffe
|
||||
@ -377,6 +374,7 @@ langchain==0.2.16
|
||||
# via quivr-diff-assistant
|
||||
langchain-anthropic==0.1.23
|
||||
# via quivr-core
|
||||
# via quivr-monorepo
|
||||
langchain-cohere==0.2.2
|
||||
# via quivr-api
|
||||
langchain-community==0.2.12
|
||||
@ -647,7 +645,6 @@ openpyxl==3.1.5
|
||||
# via unstructured
|
||||
orjson==3.10.7
|
||||
# via langsmith
|
||||
# via quivr-monorepo
|
||||
packaging==24.1
|
||||
# via deprecation
|
||||
# via faiss-cpu
|
||||
@ -852,8 +849,6 @@ python-iso639==2024.4.27
|
||||
# via unstructured
|
||||
python-jose==3.3.0
|
||||
# via quivr-api
|
||||
python-json-logger==2.0.7
|
||||
# via quivr-monorepo
|
||||
python-magic==0.4.27
|
||||
# via quivr-diff-assistant
|
||||
# via unstructured
|
||||
@ -996,8 +991,6 @@ strenum==0.4.15
|
||||
# via postgrest
|
||||
striprtf==0.0.26
|
||||
# via llama-index-readers-file
|
||||
structlog==24.4.0
|
||||
# via quivr-monorepo
|
||||
supabase==2.7.2
|
||||
# via quivr-api
|
||||
supafunc==0.5.1
|
||||
|
||||
Loading…
Reference in New Issue
Block a user