diff --git a/pdr_backend/pdr_dashboard/util/db.py b/pdr_backend/pdr_dashboard/util/db.py index 0e049a901..591ccb873 100644 --- a/pdr_backend/pdr_dashboard/util/db.py +++ b/pdr_backend/pdr_dashboard/util/db.py @@ -361,7 +361,6 @@ def payouts_from_bronze_predictions( Returns: list: List of predictions data. """ - # Start constructing the SQL query query = f"""SELECT * FROM {tbl_parquet_path(self.lake_dir, BronzePrediction)} @@ -453,6 +452,7 @@ def feeds_metrics(self) -> dict[str, Union[int, float]]: @enforce_types def predictoors_metrics(self) -> dict[str, Union[int, float]]: + query_predictoors_metrics = f""" SELECT COUNT(DISTINCT(user)) AS predictoors, @@ -521,6 +521,11 @@ def get_first_and_last_slot_timestamp(self) -> Tuple[UnixTimeS, UnixTimeS]: @enforce_types def refresh_feeds_data(self) -> None: + # Refresh the timestamps + self.min_timestamp, self.max_timestamp = ( + self.get_first_and_last_slot_timestamp() + ) + self.feeds_metrics_data = self.feeds_metrics() self.feeds_payout_stats = self._init_feed_payouts_stats() self.feeds_subscriptions = self._init_feed_subscription_stats() @@ -532,6 +537,11 @@ def refresh_feeds_data(self) -> None: @enforce_types def refresh_predictoors_data(self) -> None: + # Refresh the timestamps + self.min_timestamp, self.max_timestamp = ( + self.get_first_and_last_slot_timestamp() + ) + self.predictoors_metrics_data = self.predictoors_metrics() self.predictoors_data = self._init_predictoor_payouts_stats() @@ -715,6 +725,11 @@ def homepage_predictoors_cols(self) -> Tuple[Tuple, pl.DataFrame]: return (columns, hidden_columns), data def get_feeds_for_favourite_predictoors(self, feed_data, predictoor_addrs): + # Refresh the timestamps + self.min_timestamp, self.max_timestamp = ( + self.get_first_and_last_slot_timestamp() + ) + feed_ids = self.feed_ids_based_on_predictoors(predictoor_addrs) if not feed_ids: