#!/usr/bin/env python """Flow's exec. Run it with --help for usage.""" import datetime import logging from garcon_contrib.dynamo_feed_status import garcon_feed_status from feed_ingestion.flows.itunes import config from feed_ingestion.util import exec_utils logger = logging.getLogger(__name__) class FlowExec(exec_utils.FlowExecDaily, exec_utils.LicensorMixin): """Flow's exec.""" flow_name = config.feed_name LICENSORS = config.licensors def is_context_completed(self, context: dict, date: datetime.date): """Check if context is completed.""" self.args.expected_status = ( garcon_feed_status.STATUS_INGESTED) return super().is_context_completed(context, date) if __name__ == '__main__': FlowExec().main()