from logging import DEBUG, Logger import boto3 import ipdb from slz_dynamodb.repository import ContentStatusRepository uow_statuses = [ 'spotify-20200219-sme-aggregatedstreams-v2', 'gras-20200217-sme-gras_track-v1', 'amazonprime-20191230-sme-playlist-v1', 'amazonprime-20191210-sme-playlist-v1', 'youtubereporting-20200210-sme-asset_demographics-a1', 'amazonadsupported-20191210-sme-activity-v1', 'amazonprime-20191215-sme-user-v1', 'amazonprime-20200103-sme-user-v1', 'amazonprime-20191230-sme-activity-v1', 'amazonprime-20191212-sme-user-v1', 'amazonprime-20191212-sme-activity-v1', 'amazonprime-20200121-sme-activity-v1', 'spotify-20200205-sme-aggregatedstreams-v2', 'amazonprime-20200128-sme-activity-v1', 'amazonadsupported-20191210-sme-playlist-v1', 'amazonprime-20200103-sme-playlist-v1', 'amazonprime-20191210-sme-user-v1', 'amazonadsupported-20191230-sme-playlist-v1', 'amazonadsupported-20191215-sme-user-v1', 'amazonprime-20191210-sme-activity-v1', 'amazonprime-20191215-sme-playlist-v1', 'amazonprime-20191215-sme-activity-v1', 'amazonprime-20200102-sme-activity-v1', 'amazonadsupported-20191210-sme-user-v1', 'youtubereporting-20200203-sme-asset_demographics-a1', 'amazonadsupported-20191215-sme-playlist-v1', 'amazonprime-20200119-theorchard-playlist-v1', 'amazonprime-20191109-sme-activity-v1', 'amazonadsupported-20200207-sme-activity-v1', 'amazonprime-20200102-sme-playlist-v1', 'spotify-20200210-sme-tracks-v1', 'amazonprime-20200103-sme-activity-v1', 'amazonadsupported-20191230-sme-user-v1', 'amazonprime-20200111-sme-activity-v1', 'amazonadsupported-20191230-sme-activity-v1', 'sme_max-20200221-sme-track_mapping-v1', # broken MISSING 'spotify-20200217-sme-tracks-v1', 'amazonprime-20200131-sme-activity-v1', 'spotify-20200212-sme-aggregatedstreams-v2', 'amazonprime-20191230-sme-user-v1', 'spotify-20200203-sme-tracks-v1', 'amazonadsupported-20191212-sme-activity-v1', 'amazonadsupported-20191215-sme-activity-v1', ] def main(config): logger = Logger('test', DEBUG) dynamodb = boto3.resource('dynamodb') content_status_table = config['repository.content_status_table_name'] contest_status_repository = ContentStatusRepository(logger, content_status_table, dynamodb) ipdb.set_trace() for uow_id in uow_statuses: logger.warning("uow_id %s", uow_id) try: res = contest_status_repository.find_available(uow_id) except Exception as err: ipdb.set_trace() logger.exception(err) pass pass if __name__ == '__main__': main({'repository.content_status_table_name': 'stage-delphi-slz_content_status'})