Merge branch 'stats_data_worker' of github.com:bugout-dev/moonstream into stats_data_worker

crawlers/mooncrawl/mooncrawl/stats_worker/dashboard.py

@@ -160,6 +160,7 @@ def generate_metrics(
             )
             .order_by(text("timeseries_points DESC"))
         )
+
         response_metric: List[Any] = []
 
         for created_date, count in metrics_time_series:
@@ -374,18 +375,10 @@ def stats_generate_handler(args: argparse.Namespace):
 
         s3_client = boto3.client("s3")
 
-        # already proccessd
-
+        # Already processed
         already_processed = []
 
         for subscription in required_subscriptions.resources:
-
-            if (
-                subscription.resource_data["address"]
-                != "0x06012c8cf97BEaD5deAe237070F9587f8E7A266d"
-            ):
-                continue
-
             bucket = subscription.resource_data["bucket"]
             key = subscription.resource_data["s3_path"]
             address = subscription.resource_data["address"]
@@ -493,6 +486,9 @@ def main() -> None:
     args = parser.parse_args()
     args.func(args)
 
+    args = parser.parse_args()
+    args.func(args)
+
 
 if __name__ == "__main__":
     main()