Yohohohohohooho | Sanrei Aya
Sanrei Aya


Server : LiteSpeed
System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64
User : elvh3918 ( 1528)
PHP Version : 8.2.31
Disable Function : mail
Directory :  /usr/local/lib/python3.9/site-packages/celery/events/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //usr/local/lib/python3.9/site-packages/celery/events/__pycache__/event.cpython-39.pyc
a

��Sh��@sbdZddlZddlmZddlmZdZdZeedd�Zdeejfd	d
�Z	dd�Z
efd
d�ZdS)z/Creating events, and event exchange definition.�N)�copy)�Exchange)�Event�event_exchange�get_exchange�
group_fromZceleryevZtopic��typecKs>|r||fi|��n|}d|vr2|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
rcCs|�dd�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�}|jjdvrd|_||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).
    >ZgcpubsubZredisZfanout)rr�	transportZdriver_typer	�name)�connr�exrrrr.s
r)�__doc__�timerZkombur�__all__ZEVENT_EXCHANGE_NAMEr�dictrrrrrrr�<module>s

Yohohohohohooho | Sanrei Aya