diff --git a/openbb_platform/core/openbb_core/provider/abstract/fetcher.py b/openbb_platform/core/openbb_core/provider/abstract/fetcher.py index c8dfd2cd932..658db8435cb 100644 --- a/openbb_platform/core/openbb_core/provider/abstract/fetcher.py +++ b/openbb_platform/core/openbb_core/provider/abstract/fetcher.py @@ -10,7 +10,6 @@ from typing import ( TypeVar, get_args, get_origin, - overload, ) from pandas import DataFrame @@ -47,21 +46,34 @@ class Fetcher(Generic[Q, R]): """Transform the params to the provider-specific query.""" raise NotImplementedError - @overload @staticmethod - async def extract_data(query: Q, credentials: Optional[Dict[str, str]]) -> Any: - """Extract the data from the provider.""" + async def extract_data_async( + query: Q, credentials: Optional[Dict[str, str]] + ) -> Any: + """Asynchronously extract the data from the provider.""" @staticmethod def extract_data(query: Q, credentials: Optional[Dict[str, str]]) -> Any: """Extract the data from the provider.""" - raise NotImplementedError @staticmethod def transform_data(query: Q, data: Any, **kwargs) -> R: """Transform the provider-specific data.""" raise NotImplementedError + def __init_subclass__(cls, **kwargs): + """Initialize the subclass.""" + super().__init_subclass__(**kwargs) + + if cls.extract_data_async != Fetcher.extract_data_async: + cls.extract_data = cls.extract_data_async + elif cls.extract_data == Fetcher.extract_data: + raise NotImplementedError( + "Fetcher subclass must implement either extract_data or extract_data_async" + " method. If both are implemented, extract_data_async will be used as the" + " default." + ) + @classmethod async def fetch_data( cls, diff --git a/openbb_platform/providers/benzinga/openbb_benzinga/models/company_news.py b/openbb_platform/providers/benzinga/openbb_benzinga/models/company_news.py index 093fc2b7cea..e0049b86522 100644 --- a/openbb_platform/providers/benzinga/openbb_benzinga/models/company_news.py +++ b/openbb_platform/providers/benzinga/openbb_benzinga/models/company_news.py @@ -148,7 +148,7 @@ class BenzingaCompanyNewsFetcher( return BenzingaCompanyNewsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: BenzingaCompanyNewsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/benzinga/openbb_benzinga/models/world_news.py b/openbb_platform/providers/benzinga/openbb_benzinga/models/world_news.py index 06122066527..c13a14dc205 100644 --- a/openbb_platform/providers/benzinga/openbb_benzinga/models/world_news.py +++ b/openbb_platform/providers/benzinga/openbb_benzinga/models/world_news.py @@ -132,7 +132,7 @@ class BenzingaWorldNewsFetcher( return BenzingaWorldNewsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: BenzingaWorldNewsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/analyst_estimates.py b/openbb_platform/providers/fmp/openbb_fmp/models/analyst_estimates.py index 4b10910f1e9..a0f2658e630 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/analyst_estimates.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/analyst_estimates.py @@ -36,7 +36,7 @@ class FMPAnalystEstimatesFetcher( return FMPAnalystEstimatesQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPAnalystEstimatesQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/available_indices.py b/openbb_platform/providers/fmp/openbb_fmp/models/available_indices.py index 0b08e34a9d8..eccfa692c89 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/available_indices.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/available_indices.py @@ -45,7 +45,7 @@ class FMPAvailableIndicesFetcher( return FMPAvailableIndicesQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPAvailableIndicesQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/balance_sheet.py b/openbb_platform/providers/fmp/openbb_fmp/models/balance_sheet.py index c41fff93534..9cc79452100 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/balance_sheet.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/balance_sheet.py @@ -113,7 +113,7 @@ class FMPBalanceSheetFetcher( return FMPBalanceSheetQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPBalanceSheetQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/balance_sheet_growth.py b/openbb_platform/providers/fmp/openbb_fmp/models/balance_sheet_growth.py index 24f00d5354d..1542a7affdc 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/balance_sheet_growth.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/balance_sheet_growth.py @@ -44,7 +44,7 @@ class FMPBalanceSheetGrowthFetcher( return FMPBalanceSheetGrowthQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPBalanceSheetGrowthQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/calendar_dividend.py b/openbb_platform/providers/fmp/openbb_fmp/models/calendar_dividend.py index 82755fecfa2..b64fc3ac2f2 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/calendar_dividend.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/calendar_dividend.py @@ -80,7 +80,7 @@ class FMPCalendarDividendFetcher( return FMPCalendarDividendQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPCalendarDividendQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/calendar_earnings.py b/openbb_platform/providers/fmp/openbb_fmp/models/calendar_earnings.py index 2c1adb1942c..696df823553 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/calendar_earnings.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/calendar_earnings.py @@ -105,7 +105,7 @@ class FMPCalendarEarningsFetcher( return FMPCalendarEarningsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPCalendarEarningsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/calendar_splits.py b/openbb_platform/providers/fmp/openbb_fmp/models/calendar_splits.py index a5cde1bcf4f..b2d420700e0 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/calendar_splits.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/calendar_splits.py @@ -48,7 +48,7 @@ class FMPCalendarSplitsFetcher( return FMPCalendarSplitsQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPCalendarSplitsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/cash_flow.py b/openbb_platform/providers/fmp/openbb_fmp/models/cash_flow.py index f49cf18255d..e5d1e75f325 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/cash_flow.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/cash_flow.py @@ -120,7 +120,7 @@ class FMPCashFlowStatementFetcher( return FMPCashFlowStatementQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPCashFlowStatementQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/cash_flow_growth.py b/openbb_platform/providers/fmp/openbb_fmp/models/cash_flow_growth.py index b1304f3aed4..b3904e5e83f 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/cash_flow_growth.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/cash_flow_growth.py @@ -53,7 +53,7 @@ class FMPCashFlowStatementGrowthFetcher( return FMPCashFlowStatementGrowthQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPCashFlowStatementGrowthQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/company_filings.py b/openbb_platform/providers/fmp/openbb_fmp/models/company_filings.py index aa3901dddfc..8e4f80226bc 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/company_filings.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/company_filings.py @@ -46,7 +46,7 @@ class FMPCompanyFilingsFetcher( return FMPCompanyFilingsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPCompanyFilingsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/company_news.py b/openbb_platform/providers/fmp/openbb_fmp/models/company_news.py index 7ee4ac61d07..0637e67a5d8 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/company_news.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/company_news.py @@ -52,7 +52,7 @@ class FMPCompanyNewsFetcher( return FMPCompanyNewsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPCompanyNewsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/company_overview.py b/openbb_platform/providers/fmp/openbb_fmp/models/company_overview.py index 6fa2499c281..0e3dc0fe523 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/company_overview.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/company_overview.py @@ -47,7 +47,7 @@ class FMPCompanyOverviewFetcher( return FMPCompanyOverviewQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPCompanyOverviewQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/crypto_historical.py b/openbb_platform/providers/fmp/openbb_fmp/models/crypto_historical.py index d4b4b466b99..2a684e3581b 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/crypto_historical.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/crypto_historical.py @@ -82,7 +82,7 @@ class FMPCryptoHistoricalFetcher( return FMPCryptoHistoricalQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPCryptoHistoricalQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/crypto_search.py b/openbb_platform/providers/fmp/openbb_fmp/models/crypto_search.py index d23c68a1813..07170412109 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/crypto_search.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/crypto_search.py @@ -48,7 +48,7 @@ class FMPCryptoSearchFetcher( return FMPCryptoSearchQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPCryptoSearchQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/currency_historical.py b/openbb_platform/providers/fmp/openbb_fmp/models/currency_historical.py index 1c00a619fab..3c0330a71e9 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/currency_historical.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/currency_historical.py @@ -75,7 +75,7 @@ class FMPCurrencyHistoricalFetcher( return FMPCurrencyHistoricalQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPCurrencyHistoricalQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/currency_pairs.py b/openbb_platform/providers/fmp/openbb_fmp/models/currency_pairs.py index 3582e917165..cbb1db24ff7 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/currency_pairs.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/currency_pairs.py @@ -47,7 +47,7 @@ class FMPCurrencyPairsFetcher( return FMPCurrencyPairsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPCurrencyPairsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/discovery_filings.py b/openbb_platform/providers/fmp/openbb_fmp/models/discovery_filings.py index fe58c287fc7..2bf706871ed 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/discovery_filings.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/discovery_filings.py @@ -51,7 +51,7 @@ class FMPDiscoveryFilingsFetcher( return FMPDiscoveryFilingsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPDiscoveryFilingsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/earnings_call_transcript.py b/openbb_platform/providers/fmp/openbb_fmp/models/earnings_call_transcript.py index d33975e69b6..0c15150b725 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/earnings_call_transcript.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/earnings_call_transcript.py @@ -51,7 +51,7 @@ class FMPEarningsCallTranscriptFetcher( return FMPEarningsCallTranscriptQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEarningsCallTranscriptQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/economic_calendar.py b/openbb_platform/providers/fmp/openbb_fmp/models/economic_calendar.py index e4585136e27..4764bdb9866 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/economic_calendar.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/economic_calendar.py @@ -80,7 +80,7 @@ class FMPEconomicCalendarFetcher( return FMPEconomicCalendarQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEconomicCalendarQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/equity_historical.py b/openbb_platform/providers/fmp/openbb_fmp/models/equity_historical.py index 8a65d805e69..30dab874fc1 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/equity_historical.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/equity_historical.py @@ -80,11 +80,8 @@ class FMPEquityHistoricalFetcher( return FMPEquityHistoricalQueryParams(**transformed_params) - # TODO: Fix fetcher to allow async/sync methods or turn everything async - # @overloading the method does not work, it breaks the type hinting for the - # synchronous method implemented in other providers @staticmethod - async def extract_data( # pylint: disable=invalid-overridden-method + async def extract_data_async( query: FMPEquityHistoricalQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/equity_ownership.py b/openbb_platform/providers/fmp/openbb_fmp/models/equity_ownership.py index 9302209148e..c4e32875492 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/equity_ownership.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/equity_ownership.py @@ -51,7 +51,7 @@ class FMPEquityOwnershipFetcher( return FMPEquityOwnershipQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEquityOwnershipQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/equity_peers.py b/openbb_platform/providers/fmp/openbb_fmp/models/equity_peers.py index 141ada3d077..4ee7109d1d5 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/equity_peers.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/equity_peers.py @@ -35,7 +35,7 @@ class FMPEquityPeersFetcher( return FMPEquityPeersQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEquityPeersQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/equity_quote.py b/openbb_platform/providers/fmp/openbb_fmp/models/equity_quote.py index bb66b2f4073..c244b66d6a5 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/equity_quote.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/equity_quote.py @@ -108,7 +108,7 @@ class FMPEquityQuoteFetcher( return FMPEquityQuoteQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEquityQuoteQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/equity_screener.py b/openbb_platform/providers/fmp/openbb_fmp/models/equity_screener.py index 88e68571704..e078c92277f 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/equity_screener.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/equity_screener.py @@ -155,7 +155,7 @@ class FMPEquityScreenerFetcher( return FMPEquityScreenerQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEquityScreenerQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/equity_valuation_multiples.py b/openbb_platform/providers/fmp/openbb_fmp/models/equity_valuation_multiples.py index e7c23e0ea60..22dd4c4ba7b 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/equity_valuation_multiples.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/equity_valuation_multiples.py @@ -103,7 +103,7 @@ class FMPEquityValuationMultiplesFetcher( return FMPEquityValuationMultiplesQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEquityValuationMultiplesQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/etf_countries.py b/openbb_platform/providers/fmp/openbb_fmp/models/etf_countries.py index 803f6586b1b..5e98ad2924d 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/etf_countries.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/etf_countries.py @@ -33,7 +33,7 @@ class FMPEtfCountriesFetcher( return FMPEtfCountriesQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEtfCountriesQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/etf_holdings.py b/openbb_platform/providers/fmp/openbb_fmp/models/etf_holdings.py index 13700ab35f1..41928f6808e 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/etf_holdings.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/etf_holdings.py @@ -120,7 +120,7 @@ class FMPEtfHoldingsFetcher( return FMPEtfHoldingsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEtfHoldingsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/etf_holdings_date.py b/openbb_platform/providers/fmp/openbb_fmp/models/etf_holdings_date.py index 2ebccd9b118..b813349971a 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/etf_holdings_date.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/etf_holdings_date.py @@ -43,7 +43,7 @@ class FMPEtfHoldingsDateFetcher( return FMPEtfHoldingsDateQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEtfHoldingsDateQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/etf_holdings_performance.py b/openbb_platform/providers/fmp/openbb_fmp/models/etf_holdings_performance.py index 66a64104b65..581b9c97ca9 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/etf_holdings_performance.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/etf_holdings_performance.py @@ -35,14 +35,14 @@ class FMPEtfHoldingsPerformanceFetcher( return FMPEtfHoldingsPerformanceQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEtfHoldingsPerformanceQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, ) -> List[Dict]: """Return the raw data from the FMP endpoint.""" # Get latest available holdings filing date - dates = await FMPEtfHoldingsDateFetcher().extract_data( + dates = await FMPEtfHoldingsDateFetcher().extract_data_async( FMPEtfHoldingsDateFetcher.transform_query(query.model_dump()), credentials, **kwargs, @@ -50,7 +50,7 @@ class FMPEtfHoldingsPerformanceFetcher( if dates is None: return [] # Get holdings for that date - holdings = await FMPEtfHoldingsFetcher().extract_data( + holdings = await FMPEtfHoldingsFetcher().extract_data_async( FMPEtfHoldingsFetcher.transform_query( {"symbol": query.symbol, "date": max([d["date"] for d in dates])} ), @@ -70,7 +70,7 @@ class FMPEtfHoldingsPerformanceFetcher( holdings_str = ( ",".join(holding_chunk) if len(holding_chunk) > 1 else holding_chunk[0] ) - _performance = await FMPPricePerformanceFetcher().extract_data( + _performance = await FMPPricePerformanceFetcher().extract_data_async( FMPPricePerformanceFetcher.transform_query({"symbol": holdings_str}), credentials, **kwargs, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/etf_info.py b/openbb_platform/providers/fmp/openbb_fmp/models/etf_info.py index 96797dbf420..85f76de2b8d 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/etf_info.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/etf_info.py @@ -59,7 +59,7 @@ class FMPEtfInfoFetcher( return FMPEtfInfoQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEtfInfoQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/etf_search.py b/openbb_platform/providers/fmp/openbb_fmp/models/etf_search.py index f55d2b571a9..09d8f6ebea3 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/etf_search.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/etf_search.py @@ -87,7 +87,7 @@ class FMPEtfSearchFetcher( return FMPEtfSearchQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEtfSearchQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/etf_sectors.py b/openbb_platform/providers/fmp/openbb_fmp/models/etf_sectors.py index 748028bef13..29f3650c7e8 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/etf_sectors.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/etf_sectors.py @@ -34,7 +34,7 @@ class FMPEtfSectorsFetcher( return FMPEtfSectorsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPEtfSectorsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/executive_compensation.py b/openbb_platform/providers/fmp/openbb_fmp/models/executive_compensation.py index ffc159af525..432aa4573b2 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/executive_compensation.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/executive_compensation.py @@ -49,7 +49,7 @@ class FMPExecutiveCompensationFetcher( return FMPExecutiveCompensationQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPExecutiveCompensationQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/financial_ratios.py b/openbb_platform/providers/fmp/openbb_fmp/models/financial_ratios.py index c36cde02bb3..656dea92712 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/financial_ratios.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/financial_ratios.py @@ -56,7 +56,7 @@ class FMPFinancialRatiosFetcher( return FMPFinancialRatiosQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPFinancialRatiosQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/historical_dividends.py b/openbb_platform/providers/fmp/openbb_fmp/models/historical_dividends.py index f178196f327..17929529d9c 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/historical_dividends.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/historical_dividends.py @@ -68,7 +68,7 @@ class FMPHistoricalDividendsFetcher( return FMPHistoricalDividendsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPHistoricalDividendsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/historical_employees.py b/openbb_platform/providers/fmp/openbb_fmp/models/historical_employees.py index 291f1094322..6ab9f9bea4d 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/historical_employees.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/historical_employees.py @@ -35,7 +35,7 @@ class FMPHistoricalEmployeesFetcher( return FMPHistoricalEmployeesQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPHistoricalEmployeesQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/historical_eps.py b/openbb_platform/providers/fmp/openbb_fmp/models/historical_eps.py index 72cb1f25466..ef7e93e7435 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/historical_eps.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/historical_eps.py @@ -90,7 +90,7 @@ class FMPHistoricalEpsFetcher( return FMPHistoricalEpsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPHistoricalEpsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/historical_splits.py b/openbb_platform/providers/fmp/openbb_fmp/models/historical_splits.py index 932d9c8469b..d2171787cd8 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/historical_splits.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/historical_splits.py @@ -43,7 +43,7 @@ class FMPHistoricalSplitsFetcher( return FMPHistoricalSplitsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPHistoricalSplitsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/income_statement.py b/openbb_platform/providers/fmp/openbb_fmp/models/income_statement.py index c99776112c0..ced800f85e9 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/income_statement.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/income_statement.py @@ -143,7 +143,7 @@ class FMPIncomeStatementFetcher( return FMPIncomeStatementQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPIncomeStatementQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/income_statement_growth.py b/openbb_platform/providers/fmp/openbb_fmp/models/income_statement_growth.py index dc536fbf606..9af2d44463f 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/income_statement_growth.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/income_statement_growth.py @@ -50,7 +50,7 @@ class FMPIncomeStatementGrowthFetcher( return FMPIncomeStatementGrowthQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPIncomeStatementGrowthQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/index_constituents.py b/openbb_platform/providers/fmp/openbb_fmp/models/index_constituents.py index 9dfcea0d79c..5abcb08b897 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/index_constituents.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/index_constituents.py @@ -61,7 +61,7 @@ class FMPIndexConstituentsFetcher( return FMPIndexConstituentsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPIndexConstituentsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/insider_trading.py b/openbb_platform/providers/fmp/openbb_fmp/models/insider_trading.py index 1fb18374219..c6c507aed7e 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/insider_trading.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/insider_trading.py @@ -64,7 +64,7 @@ class FMPInsiderTradingFetcher( return FMPInsiderTradingQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPInsiderTradingQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/institutional_ownership.py b/openbb_platform/providers/fmp/openbb_fmp/models/institutional_ownership.py index cc6289dc89b..2b44334efd1 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/institutional_ownership.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/institutional_ownership.py @@ -140,7 +140,7 @@ class FMPInstitutionalOwnershipFetcher( return FMPInstitutionalOwnershipQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPInstitutionalOwnershipQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/key_executives.py b/openbb_platform/providers/fmp/openbb_fmp/models/key_executives.py index aa889f2f1be..c4c7f351ce6 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/key_executives.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/key_executives.py @@ -43,7 +43,7 @@ class FMPKeyExecutivesFetcher( return FMPKeyExecutivesQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPKeyExecutivesQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/key_metrics.py b/openbb_platform/providers/fmp/openbb_fmp/models/key_metrics.py index 6ff780e97a9..1e077803ae5 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/key_metrics.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/key_metrics.py @@ -212,7 +212,7 @@ class FMPKeyMetricsFetcher( return FMPKeyMetricsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPKeyMetricsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/market_indices.py b/openbb_platform/providers/fmp/openbb_fmp/models/market_indices.py index 485665b9374..2700d32949a 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/market_indices.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/market_indices.py @@ -81,7 +81,7 @@ class FMPMarketIndicesFetcher( return FMPMarketIndicesQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPMarketIndicesQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/market_snapshots.py b/openbb_platform/providers/fmp/openbb_fmp/models/market_snapshots.py index a6e309d749e..9ce538b3c4d 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/market_snapshots.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/market_snapshots.py @@ -92,7 +92,7 @@ class FMPMarketSnapshotsFetcher( return FMPMarketSnapshotsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPMarketSnapshotsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/price_performance.py b/openbb_platform/providers/fmp/openbb_fmp/models/price_performance.py index ab579fa036f..21d5116a8a7 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/price_performance.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/price_performance.py @@ -50,7 +50,7 @@ class FMPPricePerformanceFetcher( return FMPPricePerformanceQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPPricePerformanceQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/price_target.py b/openbb_platform/providers/fmp/openbb_fmp/models/price_target.py index 3f39e8f0b9c..2ace3270d80 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/price_target.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/price_target.py @@ -54,7 +54,7 @@ class FMPPriceTargetFetcher( return FMPPriceTargetQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPPriceTargetQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/price_target_consensus.py b/openbb_platform/providers/fmp/openbb_fmp/models/price_target_consensus.py index d8418bc8ae9..121eff65ed4 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/price_target_consensus.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/price_target_consensus.py @@ -35,7 +35,7 @@ class FMPPriceTargetConsensusFetcher( return FMPPriceTargetConsensusQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPPriceTargetConsensusQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/revenue_business_line.py b/openbb_platform/providers/fmp/openbb_fmp/models/revenue_business_line.py index bc60b257db4..ff8d95d1de3 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/revenue_business_line.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/revenue_business_line.py @@ -43,7 +43,7 @@ class FMPRevenueBusinessLineFetcher( return FMPRevenueBusinessLineQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPRevenueBusinessLineQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/revenue_geographic.py b/openbb_platform/providers/fmp/openbb_fmp/models/revenue_geographic.py index bcbda89861e..f25caa7be87 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/revenue_geographic.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/revenue_geographic.py @@ -43,7 +43,7 @@ class FMPRevenueGeographicFetcher( return FMPRevenueGeographicQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPRevenueGeographicQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/risk_premium.py b/openbb_platform/providers/fmp/openbb_fmp/models/risk_premium.py index bca1a47f795..cb52087d688 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/risk_premium.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/risk_premium.py @@ -35,7 +35,7 @@ class FMPRiskPremiumFetcher( return FMPRiskPremiumQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPRiskPremiumQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/share_statistics.py b/openbb_platform/providers/fmp/openbb_fmp/models/share_statistics.py index 1e6a4257673..85bfc78aa06 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/share_statistics.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/share_statistics.py @@ -48,7 +48,7 @@ class FMPShareStatisticsFetcher( return FMPShareStatisticsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPShareStatisticsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/treasury_rates.py b/openbb_platform/providers/fmp/openbb_fmp/models/treasury_rates.py index 7210e471d3a..38760d44321 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/treasury_rates.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/treasury_rates.py @@ -69,7 +69,7 @@ class FMPTreasuryRatesFetcher( return FMPTreasuryRatesQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPTreasuryRatesQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fmp/openbb_fmp/models/world_news.py b/openbb_platform/providers/fmp/openbb_fmp/models/world_news.py index bfcfcc9b1c9..251445315b9 100644 --- a/openbb_platform/providers/fmp/openbb_fmp/models/world_news.py +++ b/openbb_platform/providers/fmp/openbb_fmp/models/world_news.py @@ -47,7 +47,7 @@ class FMPWorldNewsFetcher( return FMPWorldNewsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FMPWorldNewsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fred/openbb_fred/models/search.py b/openbb_platform/providers/fred/openbb_fred/models/search.py index 648d5cd34f5..c102c8d783e 100644 --- a/openbb_platform/providers/fred/openbb_fred/models/search.py +++ b/openbb_platform/providers/fred/openbb_fred/models/search.py @@ -91,7 +91,7 @@ class FredSearchFetcher( return transformed_params @staticmethod - async def extract_data( + async def extract_data_async( query: FredSearchQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/fred/openbb_fred/models/series.py b/openbb_platform/providers/fred/openbb_fred/models/series.py index c9aec3093ca..3c400bbdb37 100644 --- a/openbb_platform/providers/fred/openbb_fred/models/series.py +++ b/openbb_platform/providers/fred/openbb_fred/models/series.py @@ -112,7 +112,7 @@ class FredSeriesFetcher( return FredSeriesQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: FredSeriesQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/balance_sheet.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/balance_sheet.py index bae11f540a0..e54c245c6d9 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/balance_sheet.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/balance_sheet.py @@ -109,7 +109,7 @@ class IntrinioBalanceSheetFetcher( return IntrinioBalanceSheetQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioBalanceSheetQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/calendar_ipo.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/calendar_ipo.py index 4fc84865d5d..14547f644cf 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/calendar_ipo.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/calendar_ipo.py @@ -165,7 +165,7 @@ class IntrinioCalendarIpoFetcher( return IntrinioCalendarIpoQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioCalendarIpoQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/cash_flow.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/cash_flow.py index b4ca3f995b4..eb76a3e101a 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/cash_flow.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/cash_flow.py @@ -106,7 +106,7 @@ class IntrinioCashFlowStatementFetcher( return IntrinioCashFlowStatementQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioCashFlowStatementQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/company_filings.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/company_filings.py index 64ce524f266..a712320bb63 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/company_filings.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/company_filings.py @@ -82,7 +82,7 @@ class IntrinioCompanyFilingsFetcher( return IntrinioCompanyFilingsQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioCompanyFilingsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/company_news.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/company_news.py index b1438eefa7e..42d540dc745 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/company_news.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/company_news.py @@ -61,7 +61,7 @@ class IntrinioCompanyNewsFetcher( return IntrinioCompanyNewsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioCompanyNewsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/currency_pairs.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/currency_pairs.py index 3f7576a3de3..8f11682475b 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/currency_pairs.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/currency_pairs.py @@ -47,7 +47,7 @@ class IntrinioCurrencyPairsFetcher( return IntrinioCurrencyPairsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioCurrencyPairsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_historical.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_historical.py index f7816ca8d18..776fdb3be17 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_historical.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_historical.py @@ -181,7 +181,7 @@ class IntrinioEquityHistoricalFetcher( # pylint: disable=protected-access @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioEquityHistoricalQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_info.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_info.py index 8b625c65c12..8da8799f9d3 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_info.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_info.py @@ -45,7 +45,7 @@ class IntrinioEquityInfoFetcher( return IntrinioEquityInfoQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioEquityInfoQueryParams, # pylint: disable=unused-argument credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_quote.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_quote.py index fa6a3f73d80..0a32715d043 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_quote.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_quote.py @@ -117,7 +117,7 @@ class IntrinioEquityQuoteFetcher( return IntrinioEquityQuoteQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioEquityQuoteQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/financial_attributes.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/financial_attributes.py index c638c345179..2020195c6db 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/financial_attributes.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/financial_attributes.py @@ -48,7 +48,7 @@ class IntrinioFinancialAttributesFetcher( return IntrinioFinancialAttributesQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioFinancialAttributesQueryParams, # pylint: disable=unused-argument credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/fred_series.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/fred_series.py index 034e87789fc..e87e9785ee3 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/fred_series.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/fred_series.py @@ -66,7 +66,7 @@ class IntrinioFredSeriesFetcher( return IntrinioFredSeriesQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioFredSeriesQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/historical_attributes.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/historical_attributes.py index 0c012d96f9b..67406063c05 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/historical_attributes.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/historical_attributes.py @@ -51,7 +51,7 @@ class IntrinioHistoricalAttributesFetcher( return IntrinioHistoricalAttributesQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioHistoricalAttributesQueryParams, # pylint: disable=unused-argument credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/historical_dividends.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/historical_dividends.py index 79f5e497964..f93627234d7 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/historical_dividends.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/historical_dividends.py @@ -69,7 +69,7 @@ class IntrinioHistoricalDividendsFetcher( return IntrinioHistoricalDividendsQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioHistoricalDividendsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/income_statement.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/income_statement.py index eca14070664..0395ecdba40 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/income_statement.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/income_statement.py @@ -107,7 +107,7 @@ class IntrinioIncomeStatementFetcher( return IntrinioIncomeStatementQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioIncomeStatementQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/insider_trading.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/insider_trading.py index 16000503b25..df6435541cf 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/insider_trading.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/insider_trading.py @@ -121,7 +121,7 @@ class IntrinioInsiderTradingFetcher( return IntrinioInsiderTradingQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioInsiderTradingQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/institutional_ownership.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/institutional_ownership.py index b81d3de137c..96a1e951863 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/institutional_ownership.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/institutional_ownership.py @@ -75,7 +75,7 @@ class IntrinioInstitutionalOwnershipFetcher( return IntrinioInstitutionalOwnershipQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioInstitutionalOwnershipQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/key_metrics.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/key_metrics.py index c92e47154e2..81870954876 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/key_metrics.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/key_metrics.py @@ -55,7 +55,7 @@ class IntrinioKeyMetricsFetcher( return IntrinioKeyMetricsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioKeyMetricsQueryParams, # pylint: disable=unused-argument credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/latest_attributes.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/latest_attributes.py index 4769abfa011..561b8adf17a 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/latest_attributes.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/latest_attributes.py @@ -36,7 +36,7 @@ class IntrinioLatestAttributesFetcher( return IntrinioLatestAttributesQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioLatestAttributesQueryParams, # pylint: disable=unused-argument credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/market_indices.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/market_indices.py index 2fc85384976..6c4c522d0ab 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/market_indices.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/market_indices.py @@ -67,7 +67,7 @@ class IntrinioMarketIndicesFetcher( return IntrinioMarketIndicesQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioMarketIndicesQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/options_chains.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/options_chains.py index 9afdad21fcb..0985ea3f819 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/options_chains.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/options_chains.py @@ -72,7 +72,7 @@ class IntrinioOptionsChainsFetcher( return IntrinioOptionsChainsQueryParams(**transform_params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioOptionsChainsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/options_unusual.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/options_unusual.py index c4f9462f0df..21c411c4098 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/options_unusual.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/options_unusual.py @@ -73,7 +73,7 @@ class IntrinioOptionsUnusualFetcher( return IntrinioOptionsUnusualQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioOptionsUnusualQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/search_attributes.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/search_attributes.py index bb0cbe3b123..4c922251518 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/search_attributes.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/search_attributes.py @@ -43,7 +43,7 @@ class IntrinioSearchAttributesFetcher( return IntrinioSearchAttributesQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioSearchAttributesQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/share_statistics.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/share_statistics.py index 116b625a4c9..acde1b73375 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/share_statistics.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/share_statistics.py @@ -56,7 +56,7 @@ class IntrinioShareStatisticsFetcher( return IntrinioShareStatisticsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioShareStatisticsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/world_news.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/world_news.py index 4bcbb18580b..a3b8cee6f34 100644 --- a/openbb_platform/providers/intrinio/openbb_intrinio/models/world_news.py +++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/world_news.py @@ -50,7 +50,7 @@ class IntrinioWorldNewsFetcher( return IntrinioWorldNewsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: IntrinioWorldNewsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/polygon/openbb_polygon/models/balance_sheet.py b/openbb_platform/providers/polygon/openbb_polygon/models/balance_sheet.py index 9bc0a561551..bd41da94aad 100644 --- a/openbb_platform/providers/polygon/openbb_polygon/models/balance_sheet.py +++ b/openbb_platform/providers/polygon/openbb_polygon/models/balance_sheet.py @@ -116,7 +116,7 @@ class PolygonBalanceSheetFetcher( return PolygonBalanceSheetQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: PolygonBalanceSheetQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/polygon/openbb_polygon/models/cash_flow.py b/openbb_platform/providers/polygon/openbb_polygon/models/cash_flow.py index 9fe3efeb49b..f949832092b 100644 --- a/openbb_platform/providers/polygon/openbb_polygon/models/cash_flow.py +++ b/openbb_platform/providers/polygon/openbb_polygon/models/cash_flow.py @@ -98,7 +98,7 @@ class PolygonCashFlowStatementFetcher( return PolygonCashFlowStatementQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: PolygonCashFlowStatementQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/polygon/openbb_polygon/models/company_news.py b/openbb_platform/providers/polygon/openbb_polygon/models/company_news.py index 4a14c8b07b4..d4cf979d7fa 100644 --- a/openbb_platform/providers/polygon/openbb_polygon/models/company_news.py +++ b/openbb_platform/providers/polygon/openbb_polygon/models/company_news.py @@ -84,7 +84,7 @@ class PolygonCompanyNewsFetcher( return PolygonCompanyNewsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: PolygonCompanyNewsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/polygon/openbb_polygon/models/crypto_historical.py b/openbb_platform/providers/polygon/openbb_polygon/models/crypto_historical.py index 4d94f7b1881..da0e9f3e510 100644 --- a/openbb_platform/providers/polygon/openbb_polygon/models/crypto_historical.py +++ b/openbb_platform/providers/polygon/openbb_polygon/models/crypto_historical.py @@ -81,7 +81,7 @@ class PolygonCryptoHistoricalFetcher( return PolygonCryptoHistoricalQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: PolygonCryptoHistoricalQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/polygon/openbb_polygon/models/currency_historical.py b/openbb_platform/providers/polygon/openbb_polygon/models/currency_historical.py index 504e533d558..d25f2a4cad4 100644 --- a/openbb_platform/providers/polygon/openbb_polygon/models/currency_historical.py +++ b/openbb_platform/providers/polygon/openbb_polygon/models/currency_historical.py @@ -77,7 +77,7 @@ class PolygonCurrencyHistoricalFetcher( return PolygonCurrencyHistoricalQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: PolygonCurrencyHistoricalQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/polygon/openbb_polygon/models/currency_pairs.py b/openbb_platform/providers/polygon/openbb_polygon/models/currency_pairs.py index 57df0a5ff2c..65714cb99a9 100644 --- a/openbb_platform/providers/polygon/openbb_polygon/models/currency_pairs.py +++ b/openbb_platform/providers/polygon/openbb_polygon/models/currency_pairs.py @@ -115,7 +115,7 @@ class PolygonCurrencyPairsFetcher( return PolygonCurrencyPairsQueryParams(**transform_params) @staticmethod - async def extract_data( + async def extract_data_async( query: PolygonCurrencyPairsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/polygon/openbb_polygon/models/equity_historical.py b/openbb_platform/providers/polygon/openbb_polygon/models/equity_historical.py index 6bcec1fe665..f52045b017c 100644 --- a/openbb_platform/providers/polygon/openbb_polygon/models/equity_historical.py +++ b/openbb_platform/providers/polygon/openbb_polygon/models/equity_historical.py @@ -109,7 +109,7 @@ class PolygonEquityHistoricalFetcher( return PolygonEquityHistoricalQueryParams(**transformed_params) @staticmethod - async def extract_data( # pylint: disable=protected-access + async def extract_data_async( # pylint: disable=protected-access query: PolygonEquityHistoricalQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/polygon/openbb_polygon/models/equity_nbbo.py b/openbb_platform/providers/polygon/openbb_polygon/models/equity_nbbo.py index b6457303130..78ae50e37ad 100644 --- a/openbb_platform/providers/polygon/openbb_polygon/models/equity_nbbo.py +++ b/openbb_platform/providers/polygon/openbb_polygon/models/equity_nbbo.py @@ -154,7 +154,7 @@ class PolygonEquityNBBOFetcher( return PolygonEquityNBBOQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: PolygonEquityNBBOQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/polygon/openbb_polygon/models/income_statement.py b/openbb_platform/providers/polygon/openbb_polygon/models/income_statement.py index 6c7004190c7..62456843c42 100644 --- a/openbb_platform/providers/polygon/openbb_polygon/models/income_statement.py +++ b/openbb_platform/providers/polygon/openbb_polygon/models/income_statement.py @@ -145,7 +145,7 @@ class PolygonIncomeStatementFetcher( return PolygonIncomeStatementQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: PolygonIncomeStatementQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/polygon/openbb_polygon/models/market_indices.py b/openbb_platform/providers/polygon/openbb_polygon/models/market_indices.py index a2c87ee49f4..b5f12d54901 100644 --- a/openbb_platform/providers/polygon/openbb_polygon/models/market_indices.py +++ b/openbb_platform/providers/polygon/openbb_polygon/models/market_indices.py @@ -77,7 +77,7 @@ class PolygonMarketIndicesFetcher( return PolygonMarketIndicesQueryParams(**transformed_params) @staticmethod - async def extract_data( + async def extract_data_async( query: PolygonMarketIndicesQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any, diff --git a/openbb_platform/providers/polygon/openbb_polygon/models/market_snapshots.py b/openbb_platform/providers/polygon/openbb_polygon/models/market_snapshots.py index 432fdd1507a..6a1c71febfd 100644 --- a/openbb_platform/providers/polygon/openbb_polygon/models/market_snapshots.py +++ b/openbb_platform/providers/polygon/openbb_polygon/models/market_snapshots.py @@ -101,7 +101,7 @@ class PolygonMarketSnapshotsFetcher( return PolygonMarketSnapshotsQueryParams(**params) @staticmethod - async def extract_data( + async def extract_data_async( query: PolygonMarketSnapshotsQueryParams, credentials: Optional[Dict[str, str]], **kwargs: Any,