From a7f426368dfce15f86fa0ef56200ec1228f6e4af Mon Sep 17 00:00:00 2001 From: Rodney Ewing Date: Mon, 12 Aug 2013 15:45:09 -0700 Subject: [PATCH] bulk_run reprocessing complete --- mediagoblin/gmg_commands/reprocess.py | 24 +++++++++++++++++++----- 1 file changed, 19 insertions(+), 5 deletions(-) diff --git a/mediagoblin/gmg_commands/reprocess.py b/mediagoblin/gmg_commands/reprocess.py index 55aa6cc9..3ba5d92c 100644 --- a/mediagoblin/gmg_commands/reprocess.py +++ b/mediagoblin/gmg_commands/reprocess.py @@ -111,11 +111,16 @@ def reprocess_parser_setup(subparser): help='The type of media you would like to process') bulk_run_parser.add_argument( - 'state', + '--state', default='processed', + nargs='?', help='The state of the media you would like to process. Defaults to' \ " 'processed'") + bulk_run_parser.add_argument( + 'reprocess_command', + help='The reprocess command you intend to run') + bulk_run_parser.add_argument( 'reprocess_args', nargs=argparse.REMAINDER, @@ -286,9 +291,11 @@ def available(args): print " - %s" % processor.name -def run(args): +def run(args, media_id=None): + if not media_id: + media_id = args.media_id try: - media_entry, manager = get_entry_and_processing_manager(args.media_id) + media_entry, manager = get_entry_and_processing_manager(media_id) # TODO: (maybe?) This could probably be handled entirely by the # processor class... @@ -313,12 +320,19 @@ def run(args): reprocess_info=reprocess_request) except ProcessingManagerDoesNotExist: - entry = MediaEntry.query.filter_by(id=args.media_id).first() + entry = MediaEntry.query.filter_by(id=media_id).first() print 'No such processing manager for {0}'.format(entry.media_type) def bulk_run(args): - pass + """ + Bulk reprocessing of a given media_type + """ + query = MediaEntry.query.filter_by(media_type=args.type, + state=args.state) + + for entry in query: + run(args, entry.id) def thumbs(args): -- 2.25.1