a

X>h��@sbdZd
dl
Z
d
dlmZ
d
dlmZ
dZdZeedd�Zdee
j
fd	d
�
Z	dd�Z
ef
d
d�
ZdS)z/Creating events, and event exchange definition.�N)
�copy)
�Exchange)�Event�event_exchange�get_exchange�
group_fromZceleryevZtopic�
�typecKs>|
r||
f
i|�
�
n|}d
|v
r2|j|�|d�
n||d<|S)z�Create 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__�fields�event�r�=/usr/local/lib/python3.9/site-packages/celery/events/event.pyrs



rc

Cs|�d
d�dS)z�Get 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
�
}|jjd
vrd|_|
|jkr*|
|_|S)a8
Get 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).
    >ZgcpubsubZredisZfanout)rr�	transportZdriver_typer	�name)�connr�exrrrr.s




r)�__doc__�timerZkombur�__all__ZEVENT_EXCHANGE_NAMEr�dictrrrrrrr�<module>
s