187:    profile = adapter.get_company_profile(ticker)
295:            ticker=ticker, provider=adapter.name, statement=label,
313:    bars = adapter.get_prices(ticker, start, end)
351:        provider=adapter.name,
358:def ingest_security(db: Session, adapter: ProviderAdapter, ticker: str,
373:    is_demo = adapter.tier == "DEMO"
377:    source = _get_or_create_source(db, adapter.name, adapter.tier, is_demo, f"ingest:{ticker}")
382:    # response's line items. adapter.get_balance_sheets() and adapter.get_cash_flows() were never
388:    income_periods = adapter.get_income_statements(ticker)
389:    balance_by_period = _fetch_statements_by_period(adapter, adapter.get_balance_sheets, ticker, "balance_sheets")
390:    cash_by_period = _fetch_statements_by_period(adapter, adapter.get_cash_flows, ticker, "cash_flows")
399:            quarterly_income = adapter.get_income_statements(ticker, period="quarter")
402:                           provider=adapter.name)
407:                adapter, lambda t: adapter.get_balance_sheets(t, period="quarter"), ticker,
410:                adapter, lambda t: adapter.get_cash_flows(t, period="quarter"), ticker,
424:        if secondary_adapter.tier == "DEMO" or is_demo:
429:        secondary_source = _get_or_create_source(db, secondary_adapter.name, secondary_adapter.tier, is_demo, f"ingest:{ticker}")
438:                (p.period_end, p.period_type): p for p in secondary_adapter.get_income_statements(ticker)
445:                secondary_adapter, secondary_adapter.get_balance_sheets, ticker, "balance_sheets")
447:                secondary_adapter, secondary_adapter.get_cash_flows, ticker, "cash_flows")
449:            # AUDIT FIX (Part A6, real bug caught before this shipped): EODHDAdapter.get_income_
450:            # statements/get_balance_sheets/get_cash_flows are NotImplementedError today
460:                            secondary_provider=secondary_adapter.name)
488:        secondary_tier = secondary_adapter.tier if (secondary_adapter is not None and li_b is not None) else None
492:            li, li_b, _INCOME_FIELDS, adapter.tier, secondary_tier
508:            li, li_b, _BALANCE_FIELDS, adapter.tier, secondary_tier
524:            li, li_b, _CASH_FLOW_FIELDS, adapter.tier, secondary_tier
540:            li, li_b, _SHARES_FIELDS, adapter.tier, secondary_tier
568:    logger.info("ingest.security.complete", ticker=ticker, provider=adapter.name, is_demo=is_demo,
571:                secondary_provider=(secondary_adapter.name if secondary_adapter else None))
585:        rows = adapter.get_estimates(ticker)
587:        logger.warning("ingest.estimates.not_implemented", ticker=ticker, provider=adapter.name)
627:def ingest_security_task(self, ticker: str, provider_name: str) -> str:
670:    tickers = adapter.list_universe()