class_docstr: Redis sensor for reading a message from pub sub channels.
  
  :param channels: The channels to be subscribed to (templated)
  :param redis_conn_id: the redis connection id
code: def pubsub(self):
      hook = (
          RedisHook(redis_conn_id=self.redis_conn_id)
          .get_conn()
          .pubsub()
      )
      hook.subscribe(self.channels)
      return hook
  
file_path: airflow/airflow/providers/redis/sensors/redis_pub_sub.py
imports: from __future__ import annotations
  from functools import cached_property
  from typing import TYPE_CHECKING, Sequence
  from airflow.providers.redis.hooks.redis import RedisHook
  from airflow.sensors.base import BaseSensorOperator
label_desc: Use image node_id 2 for calling the RedisPubSubSensor obj's underlying member method code with example usage: obj.pubsub() and returns: hook