"""Methods for retrieving sql2sf statuses from DynamoDB.""" import boto3 from feed_status import config as main_conf from feed_status import sql2sf_config as config dynamodb = boto3.resource('dynamodb', region_name=main_conf.AWS_REGION) STATUS_TABLE = dynamodb.Table(config.STATUS_TABLE) def get_all_statuses(): """Get all sql2fs status items. Returns: list(dict): list of dynamo items converted to dicts. One dict for one table. """ response = STATUS_TABLE.scan() return response['Items']