U Z+d@sbdZddlZddlmZddlmZdZdZeeddZdeejfd d Z d d Z efd dZ dS)z/Creating events, and event exchange definition.N)copy)Exchange)Eventevent_exchange get_exchange group_fromZceleryevZtopictypecKs:|r||f|n|}d|kr.|j||dn||d<|S)zCreate an event. Notes: An event is simply a dictionary: the only required field is ``type``. A ``timestamp`` field will be set to the current time if not provided. timestamp)r r r )update)r _fields__dict__Z__now__fieldseventr7/tmp/pip-unpacked-wheel-ucduq0nd/celery/events/event.pyrs rcCs|dddS)zGet the group part of an event type name. Example: >>> group_from('task-sent') 'task' >>> group_from('custom-my-event') 'custom' -r)splitrrrrr!s rcCs.tt}|jjdkrd|_||jkr*||_|S)a8Get exchange used for sending events. Arguments: conn (kombu.Connection): Connection used for sending/receiving events. name (str): Name of the exchange. Default is ``celeryev``. Note: The event type changes if Redis is used as the transport (from topic -> fanout). ZredisZfanout)rr transportZ driver_typer name)connrexrrrr.s   r) __doc__timerZkombur__all__ZEVENT_EXCHANGE_NAMErdictrrrrrrrs