backend/database.py
Lean MVP Database Client ========================
| Symbol | Kind | Source line |
|---|---|---|
_get_headers |
FunctionDef | L24 |
_get_base_url |
FunctionDef | L35 |
get_client |
AsyncFunctionDef | L40 |
get_boq_client |
AsyncFunctionDef | L53 |
reset_boq_client |
AsyncFunctionDef | L66 |
close_pool |
AsyncFunctionDef | L75 |
create_pipeline_run |
AsyncFunctionDef | L92 |
delete_pipeline_run |
AsyncFunctionDef | L105 |
get_latest_pipeline_run |
AsyncFunctionDef | L142 |
get_pipeline_job_counts |
AsyncFunctionDef | L163 |
refresh_pipeline_run_status |
AsyncFunctionDef | L186 |
ensure_run_materialized |
AsyncFunctionDef | L206 |
backfill_pipeline_run_statuses |
AsyncFunctionDef | L241 |
reap_stuck_pipeline_jobs |
AsyncFunctionDef | L263 |
get_pipeline_jobs_for_run |
AsyncFunctionDef | L294 |
get_pipeline_job |
AsyncFunctionDef | L320 |
enqueue_pipeline_job |
AsyncFunctionDef | L349 |
claim_pipeline_jobs |
AsyncFunctionDef | L406 |
add_pipeline_job_event |
AsyncFunctionDef | L417 |
add_gemini_call_log_row |
AsyncFunctionDef | L435 |
add_gemini_call_log_row._jsonable |
FunctionDef | L466 |
get_latest_pipeline_job_event |
AsyncFunctionDef | L567 |
get_pipeline_job_events_for_run |
AsyncFunctionDef | L588 |
extend_pipeline_job_lock |
AsyncFunctionDef | L618 |
ack_pipeline_job |
AsyncFunctionDef | L659 |
requeue_pipeline_job |
AsyncFunctionDef | L697 |
fail_pipeline_job |
AsyncFunctionDef | L742 |
create_listing |
AsyncFunctionDef | L779 |
_build_scraped_data |
FunctionDef | L899 |
get_listing |
AsyncFunctionDef | L948 |
get_listing_with_photos |
AsyncFunctionDef | L965 |
get_listings |
AsyncFunctionDef | L1000 |
update_listing |
AsyncFunctionDef | L1051 |
delete_listing |
AsyncFunctionDef | L1076 |
get_listing_photos |
AsyncFunctionDef | L1096 |
count_listings |
AsyncFunctionDef | L1117 |
check_health |
AsyncFunctionDef | L1146 |
get_listing_comparables |
AsyncFunctionDef | L1167 |
get_listing_market_stats |
AsyncFunctionDef | L1187 |
save_listing_market_stats |
AsyncFunctionDef | L1203 |
save_listing_market_stats._as_int |
FunctionDef | L1229 |
replace_listing_comparables |
AsyncFunctionDef | L1290 |
replace_listing_comparables._as_int |
FunctionDef | L1304 |
replace_listing_comparables._as_float |
FunctionDef | L1312 |
save_photo_clusters |
AsyncFunctionDef | L1388 |
get_photo_clusters |
AsyncFunctionDef | L1429 |
get_comparable_clusters |
AsyncFunctionDef | L1448 |
save_comparable_clusters |
AsyncFunctionDef | L1467 |
update_listing_year |
AsyncFunctionDef | L1508 |
save_pir |
AsyncFunctionDef | L1529 |
get_pir |
AsyncFunctionDef | L1603 |
get_pir_row |
AsyncFunctionDef | L1627 |
save_bracket_pir |
AsyncFunctionDef | L1664 |
get_bracket_pir |
AsyncFunctionDef | L1713 |
save_unified_estimate |
AsyncFunctionDef | L1744 |
get_unified_estimate |
AsyncFunctionDef | L1822 |
save_package_checkpoint |
AsyncFunctionDef | L1849 |
start_package_checkpoint |
AsyncFunctionDef | L1898 |
fail_package_checkpoint |
AsyncFunctionDef | L1907 |
get_package_checkpoints |
AsyncFunctionDef | L1917 |
clear_pipeline_data |
AsyncFunctionDef | L1939 |
save_smart_m2 |
AsyncFunctionDef | L1979 |
get_smart_m2 |
AsyncFunctionDef | L2031 |
save_v2_strategy_selection |
AsyncFunctionDef | L2065 |
get_v2_strategy_selection |
AsyncFunctionDef | L2073 |
save_v2_delta_scopes |
AsyncFunctionDef | L2078 |
get_v2_delta_scopes |
AsyncFunctionDef | L2087 |
save_v2_boq |
AsyncFunctionDef | L2095 |
get_v2_boq |
AsyncFunctionDef | L2108 |
save_boq_line_item |
AsyncFunctionDef | L2120 |
save_boq_line_items_batch |
AsyncFunctionDef | L2181 |
get_boq_line_items |
AsyncFunctionDef | L2299 |
clear_boq_line_items |
AsyncFunctionDef | L2330 |
clear_boq_line_items_by_dimension |
AsyncFunctionDef | L2361 |
count_boq_line_items |
AsyncFunctionDef | L2399 |
count_boq_line_items_by_dimension |
AsyncFunctionDef | L2431 |
create_cost_tracking_run |
AsyncFunctionDef | L2468 |
update_cost_tracking |
AsyncFunctionDef | L2509 |
complete_cost_tracking |
AsyncFunctionDef | L2577 |
get_cost_tracking_runs |
AsyncFunctionDef | L2611 |
Database |
ClassDef | L2637 |
Database.base_url |
FunctionDef | L2645 |
Database._get_headers |
FunctionDef | L2649 |
Database._get_client |
AsyncFunctionDef | L2653 |
Database.reset_boq_client |
AsyncFunctionDef | L2657 |
Database.create_pipeline_run |
AsyncFunctionDef | L2662 |
Database.delete_pipeline_run |
AsyncFunctionDef | L2665 |
Database.get_latest_pipeline_run |
AsyncFunctionDef | L2668 |
Database.get_pipeline_job_counts |
AsyncFunctionDef | L2671 |
Database.refresh_pipeline_run_status |
AsyncFunctionDef | L2674 |
Database.backfill_pipeline_run_statuses |
AsyncFunctionDef | L2677 |
Database.reap_stuck_pipeline_jobs |
AsyncFunctionDef | L2680 |
Database.get_pipeline_jobs_for_run |
AsyncFunctionDef | L2692 |
Database.get_pipeline_job |
AsyncFunctionDef | L2695 |
Database.enqueue_pipeline_job |
AsyncFunctionDef | L2698 |
Database.claim_pipeline_jobs |
AsyncFunctionDef | L2711 |
Database.ack_pipeline_job |
AsyncFunctionDef | L2714 |
Database.fail_pipeline_job |
AsyncFunctionDef | L2717 |
Database.requeue_pipeline_job |
AsyncFunctionDef | L2726 |
Database.add_pipeline_job_event |
AsyncFunctionDef | L2735 |
Database.add_gemini_call_log_row |
AsyncFunctionDef | L2744 |
Database.get_latest_pipeline_job_event |
AsyncFunctionDef | L2785 |
Database.get_pipeline_job_events_for_run |
AsyncFunctionDef | L2788 |
Database.extend_pipeline_job_lock |
AsyncFunctionDef | L2797 |
Database.get_listing |
AsyncFunctionDef | L2800 |
Database.get_listing_photos |
AsyncFunctionDef | L2803 |
Database.get_listing_comparables |
AsyncFunctionDef | L2806 |
Database.get_listing_market_stats |
AsyncFunctionDef | L2809 |
Database.get_pir_row |
AsyncFunctionDef | L2812 |
Database.save_listing_market_stats |
AsyncFunctionDef | L2815 |
Database.replace_listing_comparables |
AsyncFunctionDef | L2831 |
Database.save_photo_clusters |
AsyncFunctionDef | L2834 |
Database.get_photo_clusters |
AsyncFunctionDef | L2837 |
Database.get_comparable_clusters |
AsyncFunctionDef | L2840 |
Database.save_comparable_clusters |
AsyncFunctionDef | L2843 |
Database.update_listing_year |
AsyncFunctionDef | L2846 |
Database.save_pir |
AsyncFunctionDef | L2849 |
Database.get_pir |
AsyncFunctionDef | L2852 |
Database.save_bracket_pir |
AsyncFunctionDef | L2856 |
Database.get_bracket_pir |
AsyncFunctionDef | L2859 |
Database.save_unified_estimate |
AsyncFunctionDef | L2862 |
Database.get_unified_estimate |
AsyncFunctionDef | L2865 |
Database.save_package_checkpoint |
AsyncFunctionDef | L2868 |
Database.start_package_checkpoint |
AsyncFunctionDef | L2871 |
Database.fail_package_checkpoint |
AsyncFunctionDef | L2874 |
Database.get_package_checkpoints |
AsyncFunctionDef | L2877 |
Database.save_smart_m2 |
AsyncFunctionDef | L2881 |
Database.get_smart_m2 |
AsyncFunctionDef | L2891 |
Database.clear_pipeline_data |
AsyncFunctionDef | L2894 |
Database.upload_rendered_image |
AsyncFunctionDef | L2897 |
Database.save_v2_strategy_selection |
AsyncFunctionDef | L2962 |
Database.get_v2_strategy_selection |
AsyncFunctionDef | L2970 |
Database.save_v2_delta_scopes |
AsyncFunctionDef | L2977 |
Database.get_v2_delta_scopes |
AsyncFunctionDef | L2986 |
Database.save_v2_boq |
AsyncFunctionDef | L2994 |
Database.get_v2_boq |
AsyncFunctionDef | L3003 |
Database.save_boq_line_item |
AsyncFunctionDef | L3013 |
Database.save_boq_line_items_batch |
AsyncFunctionDef | L3024 |
Database.get_boq_line_items |
AsyncFunctionDef | L3035 |
Database.clear_boq_line_items |
AsyncFunctionDef | L3044 |
Database.clear_boq_line_items_by_dimension |
AsyncFunctionDef | L3052 |
Database.count_boq_line_items |
AsyncFunctionDef | L3066 |
Database.count_boq_line_items_by_dimension |
AsyncFunctionDef | L3074 |
Database.create_cost_tracking_run |
AsyncFunctionDef | L3090 |
Database.update_cost_tracking |
AsyncFunctionDef | L3098 |
Database.complete_cost_tracking |
AsyncFunctionDef | L3110 |
Database.get_cost_tracking_runs |
AsyncFunctionDef | L3119 |