import logging import os import redis import sys def sanitize_float(intex_float): try: intex_float = intex_float.replace(",", "") if " " in intex_float: #case of combo notes return float(intex_float.split(" ")[0]) if "(" in intex_float: return - float(intex_float[1:-1]) else: return float(intex_float) except (AttributeError, ValueError): return intex_float def get_redis_queue(): q = redis.Redis(unix_socket_path='/run/redis/redis.sock') try: q.ping() except redis.ConnectionError: try: q = redis.Redis(os.environ['REDIS_HOST']) except KeyError: logging.error("Please set redis host in REDIS_HOST") sys.exit(1) return q