:mod:`airflow.contrib.operators.redis_publish_operator`
=======================================================

.. py:module:: airflow.contrib.operators.redis_publish_operator


Module Contents
---------------

.. py:class:: RedisPublishOperator(channel, message, redis_conn_id='redis_default', *args, **kwargs)

   Bases: :class:`airflow.models.BaseOperator`

   Publish a message to Redis.

   :param channel: redis channel to which the message is published (templated)
   :type channel: str
   :param message: the message to publish (templated)
   :type message: str
   :param redis_conn_id: redis connection to use
   :type redis_conn_id: str

   .. attribute:: template_fields
      :annotation: = ['channel', 'message']

      

   
   .. method:: execute(self, context)

      Publish the message to Redis channel

      :param context: the context object
      :type context: dict