Commit d47df411 authored by arun.uday's avatar arun.uday
parents 5e03c564 1ef3c28f
...@@ -11,7 +11,9 @@ def operations_call_(json_poll_data): ...@@ -11,7 +11,9 @@ def operations_call_(json_poll_data):
1: redis_db_connection.conn_maintenance, 1: redis_db_connection.conn_maintenance,
2: redis_db_connection.conn_error 2: redis_db_connection.conn_error
} }
conn = mapper.get(json_poll_data['data_quality'])
if conn:
# insert the data to the db # insert the data to the db
insert_data(mapper.get(json_poll_data['data_quality']), json_poll_data) insert_data(conn, json_poll_data)
except Exception as e: except Exception as e:
logger.exception("Redis mapper Failed", e) logger.exception("Redis mapper Failed", e)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment