import os

env = os.environ.get('env')

if env == 'PROD':

    INGESTION_TABLE = 'prod_amazon_unlimited_feed_ingestion_statuses'
    AGGREGATION_TABLE = 'prod_amazon_unlimited_analytics_aggregation_statuses'

    SWF_INGESTION_DOMAIN = 'prod_swf_feed_ingestion'
    SWF_AGGREGATION_DOMAIN = 'prod_analytics_aggregation'

    SWF_INGESTION_WORKFLOW = 'amazon_unlimited_feed_ingestion'
    SWF_AGGREGATION_WORKFLOW = 'amazon_unlimited_sos_analytics_aggregation'

    JENKINS_INGESTION_JOB = 'prod-swf-ingestion-exec'
    JENKINS_AGGREGATION_JOB = 'prod-swf-amazon-unlimited-source-of-streams-exec'

else:
    INGESTION_TABLE = 'dev_amazon_unlimited_feed_ingestion_statuses'
    AGGREGATION_TABLE = 'dev_amazon_unlimited_analytics_aggregation_statuses'

    SWF_INGESTION_DOMAIN = 'qa_swf_feed_ingestion'
    SWF_AGGREGATION_DOMAIN = 'qa_analytics_aggregation'

    SWF_INGESTION_WORKFLOW = 'amazon_unlimited_feed_ingestion'
    SWF_AGGREGATION_WORKFLOW = 'amazon_unlimited_sos_analytics_aggregation'

    JENKINS_INGESTION_JOB = 'qa-swf-amazon-unlimited-sf-exec'
    JENKINS_AGGREGATION_JOB = 'qa-swf-amazon-unlimited-source-of-streams-exec'


INGESTION_WORKFLOW_ID_TEMPLATE = 'amazon_unlimited_feed_ingestion-{date}'

logs_directory = 'logs'

logging_format = "%(asctime)s [%(name)-15.15s][%(levelname)-7.7s] %(message)s"

parallel_ingestions_number = 1