nuclearpinguin commented on a change in pull request #6820: [AIRFLOW-6255]
Redis Hook Refactor
URL: https://github.com/apache/airflow/pull/6820#discussion_r360645106
##
File path: airflow/contrib/hooks/redis_hook.py
##
@@ -66,3 +69,47 @@ def get_conn(self):
nuclearpinguin commented on a change in pull request #6820: [AIRFLOW-6255]
Redis Hook Refactor
URL: https://github.com/apache/airflow/pull/6820#discussion_r357965814
##
File path: airflow/contrib/sensors/redis_pub_sub_sensor.py
##
@@ -40,7 +40,7 @@ def __init__(self,
nuclearpinguin commented on a change in pull request #6820: [AIRFLOW-6255]
Redis Hook Refactor
URL: https://github.com/apache/airflow/pull/6820#discussion_r357936721
##
File path: airflow/contrib/hooks/redis_hook.py
##
@@ -66,3 +66,47 @@ def get_conn(self):
nuclearpinguin commented on a change in pull request #6820: [AIRFLOW-6255]
Redis Hook Refactor
URL: https://github.com/apache/airflow/pull/6820#discussion_r357936828
##
File path: airflow/contrib/sensors/redis_pub_sub_sensor.py
##
@@ -40,7 +40,7 @@ def __init__(self,
nuclearpinguin commented on a change in pull request #6820: [AIRFLOW-6255]
Redis Hook Refactor
URL: https://github.com/apache/airflow/pull/6820#discussion_r357936768
##
File path: airflow/contrib/operators/redis_publish_operator.py
##
@@ -61,6 +61,6 @@ def execute(self,
nuclearpinguin commented on a change in pull request #6820: [AIRFLOW-6255]
Redis Hook Refactor
URL: https://github.com/apache/airflow/pull/6820#discussion_r357936601
##
File path: airflow/contrib/hooks/redis_hook.py
##
@@ -66,3 +66,47 @@ def get_conn(self):
nuclearpinguin commented on a change in pull request #6820: [AIRFLOW-6255]
Redis Hook Refactor
URL: https://github.com/apache/airflow/pull/6820#discussion_r357936630
##
File path: airflow/contrib/hooks/redis_hook.py
##
@@ -66,3 +66,47 @@ def get_conn(self):