Spaces:
Running
Running
| """ | |
| check_ammar_csv_callbacks.py -- read-only: CSV-imported leads added by Ammar Ali that have a callback | |
| scheduled, and whether each one would actually show on Pipeline right now. | |
| User request, 2026-09-23: "csv import sy Ammar Ali ny jo lead add ki hain or us me action perform kye | |
| callbacks waly, woh lead humny pipeline me add krna hai" -- Pipeline's own inScope filter | |
| (components/pipeline/pipeline-view.tsx) already shows ANY lead with callback_at set, regardless of | |
| source/who added it, automatically -- so this checks whether that's actually true for these leads, or | |
| whether something is stopping them from showing up (hidden, no callback_at despite the disposition, etc). | |
| uv run python scripts/check_ammar_csv_callbacks.py | |
| Read-only -- prints what it finds, changes nothing. | |
| """ | |
| from __future__ import annotations | |
| import sys | |
| from pathlib import Path | |
| sys.path.insert(0, str(Path(__file__).resolve().parent.parent)) | |
| from sqlalchemy import select # noqa: E402 | |
| from app.database import SessionLocal # noqa: E402 | |
| from app.models import Lead, User # noqa: E402 | |
| def main() -> int: | |
| db = SessionLocal() | |
| try: | |
| ammar = db.scalar(select(User).where(User.name.ilike("%ammar%"))) | |
| if not ammar: | |
| print("No user matching 'ammar' found.") | |
| return 1 | |
| print(f"Matched user: #{ammar.id} {ammar.name} <{ammar.email}>\n") | |
| leads = list( | |
| db.scalars( | |
| select(Lead) | |
| .where(Lead.source_prompt == "CSV Batch Import", Lead.created_by_user_id == ammar.id) | |
| .order_by(Lead.created_at) | |
| ).all() | |
| ) | |
| print(f"{len(leads)} CSV-imported lead(s) added by {ammar.name} total.\n") | |
| with_callback = [l for l in leads if l.callback_at is not None] | |
| print(f"{len(with_callback)} of those have callback_at set:\n") | |
| if not with_callback: | |
| print("(none -- if a callback disposition was applied, it should have set this; check the") | |
| print(" call_events / trace_csv_actions.py output for what outcome was actually recorded.)") | |
| return 0 | |
| for lead in with_callback: | |
| would_show = lead.hidden_at is None | |
| print(f"#{lead.id:<6} {lead.company_name}") | |
| print(f" stage={lead.pipeline_stage} callback_at={lead.callback_at} hidden_at={lead.hidden_at}") | |
| print(f" would show on Pipeline right now: {'YES' if would_show else 'NO -- hidden_at is set'}") | |
| print() | |
| return 0 | |
| finally: | |
| db.close() | |
| if __name__ == "__main__": | |
| sys.exit(main()) | |