docs: async def _send_reply(self, obj, reply):
          """Send a reply with added standard fields back to executor.
  
          :param obj: The original Channels message object to which we're
              replying.
          :param reply: The message contents dictionary. The data id is
              added automatically (``reply`` is modified in place).
          """
          reply.update({
              ExecutorProtocol.DATA_ID: obj[ExecutorProtocol.DATA_ID],
          })
          await self._call_redis(aioredis.Redis.rpush, self._queue_response_channel(obj), json.dumps(reply))