<s> from django . core . management . base import BaseCommand <EOL> from celery . task . sets import TaskSet <EOL> from olympia . amo . utils import chunked <EOL> from olympia . devhub . models import ActivityLog <EOL> from olympia . editors . tasks import add_versionlog <EOL> class Command ( BaseCommand ) : <EOL> help = '<STR_LIT>' <EOL> def handle ( self , * args , ** options ) : <EOL> pks = ( ActivityLog . objects . review_queue ( ) . values_list ( '<STR_LIT>' , flat = True ) <EOL> . order_by ( '<STR_LIT:id>' ) ) <EOL> ts = [ add_versionlog . subtask ( args = [ chunk ] ) <EOL> for chunk in chunked ( pks , <NUM_LIT:100> ) ] <EOL> TaskSet ( ts ) . apply_async ( ) </s>
