imported get current user in schema router

corrected schema.py

corrected get orgid in ai querry

corrected hf spaces

refactored analytics stream

corrected logging

refactored ai service

entityt detector

ai service refactor

refactored ai service

changed llm import

corrected llm import

refactored duck go

refactored load ml service

refactored background jobs

refactored datasource for correct payload retrieval

fixed errors

refactored registry.py

adde kpi computations import in main

added kpi computations triger

added kpi computation for retail and hospitality

refactored column embedding

resolved llm service import

fixed orgschema

added routers on main app router

ingress pipilen completion

igress pipeline completion

cleaned returned for json

imported numpy

data cleaning before insert to remove infinity numbers

added legacy schema versioning

updated version id

removed problematic schema

add querry on first api import

delete exixting schema

refactored insert funtion in mapper

added ensure schema version

refactored ingestion line

normalized column names before detection

industyr detection last refactor

fixed Bind the Parameter Outside the String

added db import

added schema versioning ,canonify save original data

added detect industry

canonical

added time limit for upstash pooling

added redis sleep time to 5 sec

reduced polling interval to 2 sec to prevent upstash deplete

imported time in mapper

cnaged datasource to call worker to querry stored raw data for entity classification