#!/usr/bin/env python
"""Flow's exec. Run it with --help for usage."""
from feed_ingestion.flows.apple_music_streams import config
from feed_ingestion.util import exec_utils


class FlowExec(exec_utils.LicensorMixin, exec_utils.FlowExecDaily):
    """Flow's exec."""

    flow_name = 'apple_music_streams'
    LICENSORS = config.licensors

    def add_args(self):
        """Add args."""
        all_reports = ', '.join(config.reports)
        self.parser.add_arg(
            'reports',
            env_var='REPORTS',
            context_key='reports',
            help=f'Comma separated list of reports to run. '
                 f'Available: {all_reports}',
            default='',
            required=False,
        )
        super().add_args()
        exec_utils.add_build_dbt_arg(
            self.parser,
        )
        exec_utils.add_arg_bool(
            self.parser,
            name='skip_mapping',
            env_var='SKIP_MAPPING',
            context_key='skip_mapping',
            help='When True the '
                 'task "update_apple_id_mapping" will be skipped',
        )


if __name__ == '__main__':
    FlowExec().main()