After restarting the redis, worker crashes #498

from pydantic import Field
from arq.connections import RedisSettings

from core.base_config import MixinSettings
from core.redis_config import redis_config
from redis.backoff import ExponentialBackoff
from redis.retry import Retry
from redis import (
   ConnectionError,
   TimeoutError
)

class ArqConfig(MixinSettings):
    redis_settings: RedisSettings = RedisSettings.from_dsn(redis_config.connection_string)
    max_jobs: int = Field(env='MAX_JOBS', default=100)
    keep_result: int = Field(env='KEEP_RESULT', default=300)

arq_config = ArqConfig()

retry = Retry(ExponentialBackoff(), 3)
arq_config.redis_settings.retry = retry
arq_config.redis_settings.retry_on_error = [ConnectionError,TimeoutError]
arq_config.redis_settings.retry_on_timeout = True

import os
import sys
sys.path.append(os.path.dirname(os.path.dirname(__file__)))

from arq.connections import RedisSettings
from core.arq_config import arq_config
from worker.calculate_anomaly import calc_anomaly
from worker.calculate_kip import calc_kip

class WorkerSettings:
    functions = [calc_anomaly,calc_kip]
    redis_settings = arq_config.redis_settings
    max_jobs = arq_config.max_jobs
    keep_result = arq_config.keep_result

redis.exceptions.ConnectionError: Connection closed by server.