#NEWLINE# def __init__( self , namespace = None , thread_task = None , migration = None , preparation = None , rollback = None , scheduler_parent = None ) : #NEWLINE# #INDENT# super ( SchedulerThread , self ) . __init__ ( namespace , migration = migration , preparation = preparation , rollback = rollback ) #NEWLINE# self . map_func_task [ WrapThreadTask ( ) ] = self . task_run_thread #NEWLINE# self . child_threads = dict ( ) #NEWLINE# self . thread_task = thread_task #NEWLINE# self . scheduler_parent = scheduler_parent