"""Script terminates flow by it's name.

Change FEED_NAME constant to specify flow name.
"""
import os
import sys

import boto.swf

from dev.utils import source
from analytics_aggregation.flows.base import generate_feed_name


ENVIRONMENT_FILE = 'dev.env'
try:
    FEED_NAME = sys.argv[1]
except IndexError:
    print('feed_name should be specified.')
    exit(1)


if __name__ == '__main__':
    source(ENVIRONMENT_FILE)
    domain = os.environ.get('DEV_DOMAIN', 'dev')
    l1 = boto.swf.layer1.Layer1(
        aws_access_key_id=os.environ.get('AWS_ACCESS_KEY_ID'),
        aws_secret_access_key=os.environ.get('AWS_SECRET_ACCESS_KEY'))
    try:
        l1.terminate_workflow_execution(domain, generate_feed_name(FEED_NAME))
        print('terminated')
    except Exception as ex:
        print('no flow found')