hvdZddlZddlmZddlmZdZdZeedZdeejfd Z d Z efd Z y) z/Creating events, and event exchange definition.N)copy)Exchange)Eventevent_exchange get_exchange group_fromceleryevtopictypec f|r ||fi|n|}d|vr|j|||S||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)rr r )update)r _fields__dict____now__fieldsevents O/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/events/event.pyrrsH,3HW ' 'E% wyt 4 Lf Lc,|jdddS)zGet the group part of an event type name. Example: >>> group_from('task-sent') 'task' >>> group_from('custom-my-event') 'custom' -r)splitr s rrr!s ::c1 a  rctt}|jjdvrd|_||j k7r||_|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). >redisgcpubsubfanout)rr transport driver_typer name)connr!exs rrr.s? n B ~~!!%:: rww Ir) __doc__timerkombur__all__EVENT_EXCHANGE_NAMErdictrrrrrr+sP5  !-G<tTYY  !0r