campaign-task

Description

Event, representing the end of a campaign task.

class CampaignTaskEvent(BaseKafkaModel):
    _topic = 'campaign_task_events'
 
    def __init__(
        self,
        campaign_id: int,
        event_type: str,
        timestamp: int = None,
        requests_batch_list: str = None,
        task_id: str = None,
        **kwargs,
    ):
        self.campaign_id = campaign_id
        self.event_type = event_type
        self.timestamp = timestamp or int(time.time())
        self.requests_batch_list = requests_batch_list
        self.task_id = task_id