fi

app.py

@@ -17,7 +17,7 @@ seafoam = Seafoam()
 
 
 def get_player_info(player_backend_user_id):
-    with open("data.json", "r", encoding="utf-8") as file:
+    with open("current_data.json", "r", encoding="utf-8") as file:
         player_info = json.load(file)
     return player_info[player_backend_user_id]
 

utils/mes_player_model.py

@@ -22,7 +22,6 @@ class Player:
     created_at_date: datetime.date = field(default_factory=date.today)
     updated_at_date: datetime.date = field(default_factory=date.today)
 
-
     def __post_init__(self):
         self.badges = self.badges.tolist()
         self.partners = self.partners.tolist()
@@ -40,4 +39,4 @@ class Player:
             Player: A Player instance.
         """
         data = series.copy()
-        return Player(**data)
+        return Player(**data)

utils/utils.py

@@ -18,10 +18,10 @@ SCOPES = ["https://www.googleapis.com/auth/bigquery"]
 SERVICE_ACCOUNT_INFO = os.getenv("GBQ_TOKEN")
 service_account_info_dict = json.loads(SERVICE_ACCOUNT_INFO)
 
-creds = Credentials.from_service_account_info(
-        service_account_info_dict, scopes=SCOPES
-    )
-client = bigquery.Client(credentials=creds, project=service_account_info_dict['project_id'])
+creds = Credentials.from_service_account_info(service_account_info_dict, scopes=SCOPES)
+client = bigquery.Client(
+    credentials=creds, project=service_account_info_dict["project_id"]
+)
 
 
 def get_content(file_name: str) -> str:
@@ -154,6 +154,7 @@ def query_bq_table(client, sql):
         logging.error(f"Query Failed: {e}")
         raise
 
+
 def load_player_statuses(client, date_str):
     table_name = f"mes_report_{date_str}"
     sql = f"SELECT * FROM `data_mart.{table_name}`"
@@ -162,19 +163,23 @@ def load_player_statuses(client, date_str):
         for _, row in query_bq_table(client, sql).iterrows()
     }
 
+
 def get_date_strs(delta_days=0):
     target_date = datetime.now().date() - timedelta(days=delta_days)
     return target_date.strftime("%Y%m%d")
 
+
 def save_latest_player_data():
-    latest_player_data = load_player_statuses(client, '20231113')
-    latest_player_data_as_dict = {key: asdict(value) for key, value in latest_player_data.items()}
+    latest_player_data = load_player_statuses(client, "20231113")
+    latest_player_data_as_dict = {
+        key: asdict(value) for key, value in latest_player_data.items()
+    }
 
     def date_serializer(obj):
         if isinstance(obj, date):
             return obj.isoformat()
         raise TypeError("Type not serializable")
-    
-    with open('latest_player_data.json', 'w') as fp:
+
+    with open("latest_player_data.json", "w") as fp:
         print("Saving latest player data...")
-        json.dump(latest_player_data_as_dict, fp, default=date_serializer)
+        json.dump(latest_player_data_as_dict, fp, default=date_serializer)