heckyel/mediagoblin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bulk_run reprocessing complete

Browse Source
This commit is contained in:
Rodney Ewing 2013-08-12 15:45:09 -07:00
parent 0c4b68a804
commit a7f426368d
1 changed files with 19 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
mediagoblin/gmg_commands/reprocess.py
View File

@ -111,11 +111,16 @@ def reprocess_parser_setup(subparser):
help='The type of media you would like to process') help='The type of media you would like to process')
bulk_run_parser.add_argument( bulk_run_parser.add_argument(
'state', '--state',
default='processed', default='processed',
nargs='?',
help='The state of the media you would like to process. Defaults to' \ help='The state of the media you would like to process. Defaults to' \
" 'processed'") " 'processed'")
bulk_run_parser.add_argument(
'reprocess_command',
help='The reprocess command you intend to run')
bulk_run_parser.add_argument( bulk_run_parser.add_argument(
'reprocess_args', 'reprocess_args',
nargs=argparse.REMAINDER, nargs=argparse.REMAINDER,
@ -286,9 +291,11 @@ def available(args):
print " - %s" % processor.name print " - %s" % processor.name
def run(args): def run(args, media_id=None):
if not media_id:
media_id = args.media_id
try: 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 # TODO: (maybe?) This could probably be handled entirely by the
# processor class... # processor class...
@ -313,12 +320,19 @@ def run(args):
reprocess_info=reprocess_request) reprocess_info=reprocess_request)
except ProcessingManagerDoesNotExist: 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) print 'No such processing manager for {0}'.format(entry.media_type)
def bulk_run(args): 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): def thumbs(args):