"""generate_label_digest task.""" from garcon import task from activity_detector import base_config from activity_detector.flows.analytics_digest import utils @task.decorate(timeout=72000) def generate_label_digest( activity, start_date, end_date, label_ids=None, last_dates_per_store=None): """Generate the digest and create the notification for each label. Args: activity (ActivityWorker): garcon activity worker start_date (str): the start date end_date (str): the end date label_ids (str): comma-separated list of account ids: 123,456,789. last_dates_per_store ([dict]): the list of last date per store Returns: None """ utils.generate_digest( base_config.ACCOUNT_TYPE_LABEL, start_date, end_date, label_ids, last_dates_per_store)