From 780556dc52d4ee2f4edee28f4128a823dec2546f Mon Sep 17 00:00:00 2001 From: David Lehuby Date: Tue, 13 Aug 2024 13:53:33 +1000 Subject: [PATCH] PM-1923 - Soft fail next epoch staking-ledger processing --- .../scripts/mina-staking-ledgers-exporter.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/mina-staking-ledgers-exporter/scripts/mina-staking-ledgers-exporter.py b/mina-staking-ledgers-exporter/scripts/mina-staking-ledgers-exporter.py index 295ef80e..7e237327 100755 --- a/mina-staking-ledgers-exporter/scripts/mina-staking-ledgers-exporter.py +++ b/mina-staking-ledgers-exporter/scripts/mina-staking-ledgers-exporter.py @@ -15,13 +15,13 @@ class config: - api_enabled = os.environ.get("APP_MINA_PAYOUTS_DATA_PROVIDER_ENABLED", False).lower() == "true" + api_enabled = os.environ.get("APP_MINA_PAYOUTS_DATA_PROVIDER_ENABLED", "false" ).lower() == "true" api_password = os.environ["APP_MINA_PAYOUTS_DATA_PROVIDER_PASSWORD"] api_url = os.environ["APP_MINA_PAYOUTS_DATA_PROVIDER_URL"] api_username = os.environ["APP_MINA_PAYOUTS_DATA_PROVIDER_USERNAME"] mina_node_label = os.environ["APP_MINA_NODE_LABEL"] network = os.environ["APP_NETWORK"] - s3_enabled = os.environ.get("APP_S3_ENABLED", False).lower() == "true" + s3_enabled = os.environ.get("APP_S3_ENABLED", "false" ).lower() == "true" s3_bucket = os.environ["APP_S3_BUCKET"] s3_subpath = os.environ.get("APP_S3_SUBPATH", "") slack_webhook_info_url = os.environ["APP_SLACK_WEBHOOK_INFO_URL"] @@ -40,7 +40,10 @@ def main(): logger.info(f" -- Processing current epoch ({current_epoch}) --") process_staking_ledger(synced_pod, current_epoch, "staking-epoch-ledger") logger.info(f" -- Processing next epoch ({next_epoch}) --") - process_staking_ledger(synced_pod, next_epoch, "next-epoch-ledger") + try: + process_staking_ledger(synced_pod, next_epoch, "next-epoch-ledger") + except Exception as e: + logger.warning(f"Unable to process the next epoch {next_epoch} due to error: {e}, skipping further processing.") logger.info("Complete with success")