diff options
| -rw-r--r-- | python/process_queue.py | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index f881949d..7e8eb0cf 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -1,4 +1,5 @@ import redis +import socket import pandas as pd import csv import sys @@ -22,7 +23,11 @@ def decode_dict(d): v.decode() if isinstance(v, bytes) else v for k, v in d.items()} def get_redis_queue(): - return redis.Redis(host = 'debian') + hostname = socket.gethostname() + if hostname == 'debian': + return redis.Redis(unix_socket_path='/var/run/redis/redis.sock') + else: + return redis.Redis(host = 'debian') def aux(v): if v.action.iat[-1] == 'CANCEL': |