hammering

removed redis hammering

stop build from depleting upstash

corrected mapper

remode canonical

refactored mapper and analytics worker

eroor fixed

chnaged ananlytics worker

-check canonify triger timing-review worker startup and wait logic

removed origin fro github

added redis emiter

added fallback entity and industry to be streamed to reddis

added redis streams endpoint

fixed import issues

refactored all querries

removed rate limiter from poll recent api

refacroed compute endpoint

registered analytics stream in main,.py

refactored analytics engine

refactored emit analytics triger

refactore worker manager

stop

cleaned worker manager

fixed analytics event emmiter

added https instead of pub/redis

fixed redis_async_client

refactored worker manager

resolved orgid import

corrected schemas import

corrected org_schema

resolved analytics worker import issues

imported json in main

fixed all errors

fixeda all errors

fixed errors

added loging on datasource and removed kpi computation trigger

commented import logigng

imported loging in datasource

fixed indentation on mapper

fixed indentation issues

fixed indentation issue

fixed indentation issue

aded safe redis decode

corrected datasource and canonify

removed background jobs on datasource endpoint

imported datetime in depts

added is loading property

imported pathlib in main

fixed:imported dict ,list and union

fixed schema router