"""
Theatrical cuts ETL Command Line Interface.

All required methods to setup and execute the command line for theatrical_cuts
related tasks are in here.
"""

from time import sleep

from garcon.activity import ActivityWorker
from garcon.decider import DeciderWorker

from flows import config as base_config
from flows.theatrical_cuts import config
from flows.theatrical_cuts.flow import Flow


def init_worker_parser(parser):
    """Setup the 'worker theatrical_cuts' sub-command to the cli.

    Args:
        parser (argparse.ArgumentParser): sub-command argument parser.
    """
    pass


def run_worker():
    """CLI entry point to the 'worker theatrical_cuts' sub-command."""
    worker = ActivityWorker(Flow(
        base_config.SWF_DOMAIN, config.SWF_WORKFLOW_NAME,
        config.SWF_WORKFLOW_VERSION))
    worker.run()


def init_decider_parser(parser):
    """Setup the 'decider theatrical_cuts' sub-command to the cli.

    Args:
        parser (argparse.ArgumentParser): sub-command argument parser.
    """
    pass


def run_decider():
    """CLI entry point to the 'decider theatrical_cuts' sub-command."""
    decider = DeciderWorker(Flow(
        base_config.SWF_DOMAIN, config.SWF_WORKFLOW_NAME,
        config.SWF_WORKFLOW_VERSION))
    while True:
        decider.run()
        sleep(1)