"""YouTube Bulk Facts Asset Reports Workflow.""" from garcon.param import StaticParam from feed_ingestion.flows import base from feed_ingestion.flows.base import FlowBase from feed_ingestion.flows.youtube_bulk_reports import tasks from feed_ingestion.flows.youtube_bulk_reports.flow import GroupFlow from feed_ingestion.flows.youtube_bulk_reports_facts_asset import config class Flow(GroupFlow): """Class representing the workflow.""" def __init__(self): """Initialize flow object.""" FlowBase.__init__(self, config.feed_name, config.feed_version) @property def bootstrap(self): """Bootstrap initial configuration.""" return self.create( name='bootstrap', tasks=base.SyncRunner( tasks.bootstrap_report_group.fill( namespace='bootstrap', feed_name=StaticParam(config.feed_name), date='context_date', licensor='licensor', reload='reload', report_list=StaticParam(config.report_list))))