This commit is contained in:
@@ -84,9 +84,11 @@ async def get_analytics(
|
||||
continents: str = None
|
||||
):
|
||||
# Determine if we need to join metadata
|
||||
# Determine if we need to join metadata
|
||||
composite_keys = ["exchange_continent", "exchange_sector"]
|
||||
needs_metadata = any([
|
||||
group_by in ["name", "continent", "sector"],
|
||||
sub_group_by in ["name", "continent", "sector"],
|
||||
group_by in ["name", "continent", "sector"] + composite_keys,
|
||||
sub_group_by in ["name", "continent", "sector"] + composite_keys,
|
||||
continents is not None
|
||||
])
|
||||
|
||||
@@ -107,7 +109,9 @@ async def get_analytics(
|
||||
"isin": f"{t_prefix}isin",
|
||||
"name": f"coalesce({m_prefix}name, {t_prefix}isin)" if needs_metadata else "isin",
|
||||
"continent": f"coalesce({m_prefix}continent, 'Unknown')" if needs_metadata else "'Unknown'",
|
||||
"sector": f"coalesce({m_prefix}sector, 'Unknown')" if needs_metadata else "'Unknown'"
|
||||
"sector": f"coalesce({m_prefix}sector, 'Unknown')" if needs_metadata else "'Unknown'",
|
||||
"exchange_continent": f"concat({t_prefix}exchange, ' - ', coalesce({m_prefix}continent, 'Unknown'))" if needs_metadata else "'Unknown'",
|
||||
"exchange_sector": f"concat({t_prefix}exchange, ' - ', coalesce({m_prefix}sector, 'Unknown'))" if needs_metadata else "'Unknown'"
|
||||
}
|
||||
|
||||
selected_metric = metrics_map.get(metric, metrics_map["volume"])
|
||||
|
||||
Reference in New Issue
Block a user