(self, client: "lightbus.client.BusClient", event_name_, **kwargs)
return client.fire_event(
            api_name="internal.metrics", name=event_name_, kwargs=kwargs, options={}
        )
Send an event to the bus
Send an event to the bus
Send an event to the bus
def send_event(self, client: "lightbus.client.BusClient", event_name_, **kwargs) -> Coroutine:
        """Send an event to the bus
        """
        kwargs.setdefault("timestamp", datetime.utcnow().timestamp())
        kwargs.setdefault("service_name", self.service_name)
        kwargs.setdefault("process_name", self.process_name)
        kwargs = deform_to_bus(kwargs)

        return client.fire_event(
            api_name="internal.metrics", name=event_name_, kwargs=kwargs, options={}
        )
def send_event ( self , client : "lightbus.client.BusClient" , event_name_ , * * kwargs ) -> Coroutine : kwargs . setdefault ( "timestamp" , datetime . utcnow ( ) . timestamp ( ) ) kwargs . setdefault ( "service_name" , self . service_name ) kwargs . setdefault ( "process_name" , self . process_name ) kwargs = deform_to_bus ( kwargs ) return client . fire_event ( api_name = "internal.metrics" , name = event_name_ , kwargs = kwargs , options = { } )