code: def test_poke_mock_true(self, mock_redis_conn):
      sensor = RedisPubSubSensor(
          task_id="test_task",
          dag=self.dag,
          channels="test",
          redis_conn_id="redis_default",
      )
  
      mock_redis_conn().pubsub().get_message.return_value = {
          "type": "message",
          "channel": b"test",
          "data": b"d1",
      }
  
      result = sensor.poke(self.mock_context)
      assert result
  
      context_calls = [
          call.xcom_push(
              key="message",
              value={
                  "type": "message",
                  "channel": b"test",
                  "data": b"d1",
              },
          )
      ]
  
      assert (
          self.mock_context["ti"].method_calls == context_calls
      ), "context call  should be same"
  
file_path: airflow/tests/providers/redis/sensors/test_redis_pub_sub.py
imports: from __future__ import annotations
  from unittest.mock import MagicMock, call, patch
  from airflow.models.dag import DAG
  from airflow.providers.redis.sensors.redis_pub_sub import RedisPubSubSensor
  from airflow.utils import timezone
label_desc: Use image node_id 2 for calling the TestRedisPubSubSensor obj's underlying member method code with example usage: obj.test_poke_mock_true(mock_redis_conn) without return types