time

Description

Can be useful to provide a signal of a new day came.

class TimeEvent(BaseKafkaModel):
    _topic = 'time'
 
    def __init__(self, new_day: bool, timestamp: int = None, **kwargs):
        super(TimeEvent, self).__init__(**kwargs)
        self.new_day = new_day
        self.timestamp = timestamp or int(time.time())