diff --git a/app/config.py b/app/config.py index f087c69eaa..0481b5af82 100644 --- a/app/config.py +++ b/app/config.py @@ -585,7 +585,7 @@ class Config(object): # Timestamp in epoch milliseconds to seed the bounce rate. We will seed data for (24, the below config) included. FF_BOUNCE_RATE_SEED_EPOCH_MS = os.getenv("FF_BOUNCE_RATE_SEED_EPOCH_MS", False) # Feature flag to enable custom retry policies such as lowering retry period for certain priority lanes. - FF_CELERY_CUSTOM_RETRY_POLICIES = env.bool("FF_CELERY_CUSTOM_RETRY_POLICIES", False) + FF_CELERY_CUSTOM_TASK_PARAMS = env.bool("FF_CELERY_CUSTOM_TASK_PARAMS", False) FF_CLOUDWATCH_METRICS_ENABLED = env.bool("FF_CLOUDWATCH_METRICS_ENABLED", False) # Feature flags for email_daily_limit FF_EMAIL_DAILY_LIMIT = env.bool("FF_EMAIL_DAILY_LIMIT", False) @@ -654,8 +654,8 @@ class Development(Config): API_HOST_NAME = "http://localhost:6011" API_RATE_LIMIT_ENABLED = True - - FF_CELERY_CUSTOM_RETRY_POLICIES = True + + FF_CELERY_CUSTOM_TASK_PARAMS = True class Test(Development): @@ -691,7 +691,7 @@ class Test(Development): CRM_GITHUB_PERSONAL_ACCESS_TOKEN = "test-token" CRM_ORG_LIST_URL = "https://test-url.com" - FF_CELERY_CUSTOM_RETRY_POLICIES = True + FF_CELERY_CUSTOM_TASK_PARAMS = True FF_EMAIL_DAILY_LIMIT = False diff --git a/app/notifications/process_notifications.py b/app/notifications/process_notifications.py index 390cc43d1d..17083d9a07 100644 --- a/app/notifications/process_notifications.py +++ b/app/notifications/process_notifications.py @@ -231,7 +231,7 @@ def build_delivery_task_params(notification_type: str, notification_process_type If the notification is a high priority SMS, set the retry policy to retry every 25 seconds else fall back to the default retry policy of retrying every 5 minutes. """ - if current_app.config["FF_CELERY_CUSTOM_RETRY_POLICIES"]: + if current_app.config["FF_CELERY_CUSTOM_TASK_PARAMS"]: return {} params: dict[str, Any] = {}