chore: add more logs

api/services/billing_service.py

@@ -143,6 +143,7 @@ class BillingService:
                 raise ValueError("Invalid arguments.")
         if method == "POST" and response.status_code != httpx.codes.OK:
             raise ValueError(f"Unable to send request to {url}. Please try again later or contact support.")
+        logger.info("billing_service: %s _send_request: response: %s", method, response.json())
         return response.json()
 
     @staticmethod
@@ -165,6 +166,7 @@ class BillingService:
     def delete_account(cls, account_id: str):
         """Delete account."""
         params = {"account_id": account_id}
+        logger.info("billing_service: delete_account: params: %s", params)
         return cls._send_request("DELETE", "/account/", params=params)
 
     @classmethod

api/tasks/delete_account_task.py

@@ -14,10 +14,13 @@ logger = logging.getLogger(__name__)
 @shared_task(queue="dataset")
 def delete_account_task(account_id):
     with session_factory.create_session() as session:
+        logger.info("delete_account_task: account_id: %s", account_id)
         account = session.query(Account).where(Account.id == account_id).first()
         try:
             if dify_config.BILLING_ENABLED:
+                logger.info("delete_account_task: before delete_account: %s", account_id)
                 BillingService.delete_account(account_id)
+                logger.info("delete_account_task: after delete_account: %s", account_id)
         except Exception:
             logger.exception("Failed to delete account %s from billing service.", account_id)
             raise
@@ -27,3 +30,4 @@ def delete_account_task(account_id):
             return
         # send success email
         send_deletion_success_task.delay(account.email)
+        logger.info("delete_account_task: delete_account successfully: %s", account_id)