()
| 18 | |
| 19 | |
| 20 | def get_redis_connection(): |
| 21 | from redis import StrictRedis |
| 22 | |
| 23 | host = os.environ.get("REDIS_HOST", "localhost") |
| 24 | port = os.environ.get("REDIS_PORT", 6379) |
| 25 | return StrictRedis(host=host, port=port) |
| 26 | |
| 27 | |
| 28 | logger = get_task_logger(__name__) |