diff --git a/onadata/libs/utils/cache_tools.py b/onadata/libs/utils/cache_tools.py index ce4e3dfb9d..24a2897609 100644 --- a/onadata/libs/utils/cache_tools.py +++ b/onadata/libs/utils/cache_tools.py @@ -83,7 +83,7 @@ ELIST_NUM_ENTITIES_CREATED_AT = f"{ELIST_NUM_ENTITIES_IDS}-created-at" # Report exception -ELIST_FAILOVER_REPORT = "elist-failover-report-sent" +ELIST_FAILOVER_REPORT_SENT = "elist-failover-report-sent" def safe_delete(key): diff --git a/onadata/libs/utils/logger_tools.py b/onadata/libs/utils/logger_tools.py index f251487eda..6393311351 100644 --- a/onadata/libs/utils/logger_tools.py +++ b/onadata/libs/utils/logger_tools.py @@ -98,7 +98,7 @@ ELIST_NUM_ENTITIES_IDS, ELIST_NUM_ENTITIES_LOCK, ELIST_NUM_ENTITIES_CREATED_AT, - ELIST_FAILOVER_REPORT, + ELIST_FAILOVER_REPORT_SENT, safe_delete, set_cache_with_lock, ) @@ -1330,7 +1330,7 @@ def _exec_cached_elist_counter_commit_failover() -> None: if time_lapse.total_seconds() > failover_timeout: commit_cached_elist_num_entities() # Do not send report exception if already sent within the past 24 hrs - if cache.get(ELIST_FAILOVER_REPORT) is None: + if cache.get(ELIST_FAILOVER_REPORT_SENT) is None: subject = "Periodic task not running" task_name = ( "onadata.apps.logger.tasks.commit_cached_elist_num_entities_async" @@ -1340,4 +1340,4 @@ def _exec_cached_elist_counter_commit_failover() -> None: "is not configured or has malfunctioned" ) report_exception(subject, msg) - cache.set(ELIST_FAILOVER_REPORT, "sent", 86400) + cache.set(ELIST_FAILOVER_REPORT_SENT, "sent", 86400)