Module Import alias Import alias Import alias Import alias Import alias ImportFrom alias Import alias Import alias Import alias ImportFrom alias ImportFrom alias FunctionDef arguments args defaults body Assign NameStore Call NameLoad Assign NameStore Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr For NameStore Call AttributeLoad NameLoad attr body If Call AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Return NameLoad decorator_list FunctionDef arguments args defaults body If UnaryOpNot Call AttributeLoad NameLoad attr body Expr Yield TryFinally body Expr Call AttributeLoad NameLoad attr Expr Yield finalbody Expr Call AttributeLoad NameLoad attr decorator_list AttributeLoad NameLoad attr ClassDef bases AttributeLoad NameLoad attr body FunctionDef arguments args NameParam defaults body Return ListComp Call NameLoad NameLoad comprehension NameStore Call NameLoad Num decorator_list decorator_list ClassDef bases AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Num Return NameLoad decorator_list decorator_list ClassDef bases AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Return BoolOpOr CompareLt AttributeLoad NameLoad attr AttributeLoad NameLoad attr CompareEq AttributeLoad NameLoad attr Num decorator_list FunctionDef arguments args NameParam defaults body Return ListComp Call NameLoad BinOpSub AttributeLoad NameLoad attr Num NameLoad comprehension NameStore Call NameLoad BinOpAdd AttributeLoad NameLoad attr Num decorator_list decorator_list ClassDef bases AttributeLoad NameLoad attr body FunctionDef arguments args NameParam defaults body Assert NameLoad decorator_list decorator_list ClassDef bases AttributeLoad NameLoad attr body FunctionDef arguments args NameParam defaults body Assert NameLoad decorator_list decorator_list ClassDef bases AttributeLoad NameLoad attr body FunctionDef arguments args NameParam defaults body ClassDef bases NameLoad body Pass decorator_list Raise Call NameLoad decorator_list decorator_list ClassDef bases AttributeLoad NameLoad attr body FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call NameLoad keyword AttributeLoad NameLoad attr keyword Str decorator_list FunctionDef arguments args NameParam NameParam defaults body Return ListComp SubscriptLoad NameLoad Index Str comprehension TupleStore NameStore NameStore AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr CompareEq SubscriptLoad NameLoad Index Str NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad With Call NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call NameLoad Num Num keyword NameLoad Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call NameLoad Num Num NameLoad Expr Call AttributeLoad NameLoad attr Num AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Expr Call AttributeLoad NameLoad attr Call NameLoad TupleLoad AttributeLoad Call NameLoad keyword Num keyword Num attr AttributeLoad Call NameLoad keyword Num keyword Num attr AttributeLoad Call NameLoad keyword Num keyword Num attr AttributeLoad Call NameLoad keyword Num keyword Num attr AttributeLoad Call NameLoad keyword Num keyword Num attr AttributeLoad Call NameLoad keyword Num keyword Num attr AttributeLoad Call NameLoad keyword Num keyword Num attr AttributeLoad Call NameLoad keyword Num keyword Num attr Call NameLoad Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr Call NameLoad TupleLoad AttributeLoad Call NameLoad keyword Num keyword Num attr AttributeLoad Call NameLoad keyword Num keyword Num attr AttributeLoad Call NameLoad keyword Num keyword Num attr AttributeLoad Call NameLoad keyword Num keyword Num attr AttributeLoad Call NameLoad keyword Num keyword Num attr AttributeLoad Call NameLoad keyword Num keyword Num attr AttributeLoad Call NameLoad keyword Num keyword Num attr Call NameLoad Call AttributeLoad NameLoad attr Str decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad SubscriptLoad SubscriptLoad AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Index Num Index Str Expr Call AttributeLoad NameLoad attr SubscriptLoad SubscriptLoad AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Index Num Index Str Expr Call AttributeLoad NameLoad attr CompareIn Str SubscriptLoad SubscriptLoad AttributeLoad NameLoad attr Index Num Index Num decorator_list Call AttributeLoad NameLoad attr Str FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad Call NameLoad attr TryExcept body Expr Call AttributeLoad Call NameLoad attr handlers ExceptHandler type NameLoad name NameStore body Assign NameStore NameLoad Expr Call AttributeLoad NameLoad attr TupleLoad AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad SubscriptLoad SubscriptLoad AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Index Num Index Str Expr Call AttributeLoad NameLoad attr SubscriptLoad SubscriptLoad AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Index Num Index Str Expr Call AttributeLoad NameLoad attr CompareIn Str SubscriptLoad SubscriptLoad AttributeLoad NameLoad attr Index Num Index Num decorator_list Call AttributeLoad NameLoad attr Str FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad SubscriptLoad SubscriptLoad AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Index Num Index Str Expr Call AttributeLoad NameLoad attr SubscriptLoad SubscriptLoad AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Index Num Index Str decorator_list Call AttributeLoad NameLoad attr Str decorator_list If CompareEq NameLoad Str body Expr Call AttributeLoad NameLoad attr
N/A N/A contextlib N/A gc N/A os N/A pickle N/A time helpers unittest N/A luigi N/A mock N/A psutil luigi.worker Worker luigi.task_status UNKNOWN running_children N/A N/A N/A N/A N/A children N/A set N/A process N/A N/A psutil Process N/A N/A os getpid N/A child N/A N/A process children N/A N/A N/A N/A child is_running N/A N/A N/A N/A children add N/A child pid N/A children N/A pause_gc N/A N/A N/A N/A N/A N/A N/A N/A gc isenabled N/A N/A N/A N/A N/A N/A N/A N/A gc disable N/A N/A N/A N/A N/A N/A gc enable N/A N/A contextlib contextmanager SlowCompleteWrapper N/A N/A luigi WrapperTask N/A requires N/A N/A self N/A N/A N/A N/A N/A SlowCompleteTask i N/A i N/A range 4 N/A N/A SlowCompleteTask N/A N/A luigi Task N/A N/A n N/A N/A luigi IntParameter complete N/A N/A self N/A N/A N/A N/A N/A time sleep 0.1 N/A True N/A N/A OverlappingSelfDependenciesTask N/A N/A luigi Task N/A N/A n N/A N/A luigi IntParameter N/A k N/A N/A luigi IntParameter complete N/A N/A self N/A N/A N/A N/A N/A N/A self n N/A self k N/A N/A self k 0 N/A requires N/A N/A self N/A N/A N/A N/A N/A OverlappingSelfDependenciesTask N/A N/A self n 1 k N/A k N/A range N/A N/A self k 1 N/A N/A ExceptionCompleteTask N/A N/A luigi Task N/A complete N/A N/A self N/A N/A N/A False N/A N/A ExceptionRequiresTask N/A N/A luigi Task N/A requires N/A N/A self N/A N/A N/A False N/A N/A UnpicklableExceptionTask N/A N/A luigi Task N/A complete N/A N/A self N/A N/A UnpicklableException N/A Exception N/A N/A N/A N/A N/A UnpicklableException N/A N/A ParallelSchedulingTest N/A N/A unittest TestCase N/A setUp N/A N/A self N/A N/A N/A N/A self sch N/A N/A mock Mock N/A N/A self w N/A Worker scheduler N/A self sch worker_id x N/A added_tasks N/A N/A self status N/A N/A N/A N/A N/A kw N/A task_id N/A N/A args kw N/A N/A N/A self sch add_task call_args_list N/A N/A kw N/A status status N/A test_children_terminated N/A N/A self N/A N/A N/A before_children N/A running_children N/A N/A pause_gc N/A N/A N/A N/A N/A self w add N/A OverlappingSelfDependenciesTask 5 2 multiprocess True N/A N/A N/A self assertLessEqual N/A running_children before_children N/A test_multiprocess_scheduling_with_overlapping_dependencies N/A N/A self N/A N/A N/A N/A N/A N/A self w add N/A OverlappingSelfDependenciesTask 5 2 True N/A N/A N/A self assertEqual 15 N/A N/A N/A self sch add_task call_count N/A N/A N/A self assertEqual N/A set N/A N/A N/A OverlappingSelfDependenciesTask n 1 k 1 task_id N/A N/A OverlappingSelfDependenciesTask n 2 k 1 task_id N/A N/A OverlappingSelfDependenciesTask n 2 k 2 task_id N/A N/A OverlappingSelfDependenciesTask n 3 k 1 task_id N/A N/A OverlappingSelfDependenciesTask n 3 k 2 task_id N/A N/A OverlappingSelfDependenciesTask n 4 k 1 task_id N/A N/A OverlappingSelfDependenciesTask n 4 k 2 task_id N/A N/A OverlappingSelfDependenciesTask n 5 k 2 task_id N/A set N/A N/A self added_tasks PENDING N/A N/A N/A self assertEqual N/A set N/A N/A N/A OverlappingSelfDependenciesTask n 0 k 0 task_id N/A N/A OverlappingSelfDependenciesTask n 0 k 1 task_id N/A N/A OverlappingSelfDependenciesTask n 1 k 0 task_id N/A N/A OverlappingSelfDependenciesTask n 1 k 2 task_id N/A N/A OverlappingSelfDependenciesTask n 2 k 0 task_id N/A N/A OverlappingSelfDependenciesTask n 3 k 0 task_id N/A N/A OverlappingSelfDependenciesTask n 4 k 0 task_id N/A set N/A N/A self added_tasks DONE N/A test_raise_exception_in_complete N/A N/A self send N/A N/A N/A N/A N/A N/A self w add N/A ExceptionCompleteTask multiprocess True N/A N/A N/A send check_called_once N/A N/A N/A self assertEqual UNKNOWN N/A N/A N/A N/A N/A self sch add_task call_args N/A 1 N/A status N/A N/A N/A self assertFalse N/A N/A N/A N/A N/A self sch add_task call_args N/A 1 N/A runnable N/A N/A N/A self assertTrue N/A assert False N/A N/A N/A send call_args N/A 0 N/A 1 N/A N/A N/A mock patch luigi.notifications.send_error_email test_raise_unpicklable_exception_in_complete N/A N/A self send N/A N/A N/A N/A N/A self assertRaises Exception N/A N/A UnpicklableExceptionTask complete N/A N/A N/A N/A N/A N/A UnpicklableExceptionTask complete N/A N/A N/A Exception N/A e N/A N/A ex e N/A N/A N/A self assertRaises N/A N/A pickle PicklingError AttributeError N/A pickle dumps ex N/A N/A N/A N/A self w add N/A UnpicklableExceptionTask multiprocess True N/A N/A N/A send check_called_once N/A N/A N/A self assertEqual UNKNOWN N/A N/A N/A N/A N/A self sch add_task call_args N/A 1 N/A status N/A N/A N/A self assertFalse N/A N/A N/A N/A N/A self sch add_task call_args N/A 1 N/A runnable N/A N/A N/A self assertTrue N/A raise UnpicklableException() N/A N/A N/A send call_args N/A 0 N/A 1 N/A N/A N/A mock patch luigi.notifications.send_error_email test_raise_exception_in_requires N/A N/A self send N/A N/A N/A N/A N/A N/A self w add N/A ExceptionRequiresTask multiprocess True N/A N/A N/A send check_called_once N/A N/A N/A self assertEqual UNKNOWN N/A N/A N/A N/A N/A self sch add_task call_args N/A 1 N/A status N/A N/A N/A self assertFalse N/A N/A N/A N/A N/A self sch add_task call_args N/A 1 N/A runnable N/A N/A N/A mock patch luigi.notifications.send_error_email N/A N/A N/A __name__ __main__ N/A N/A N/A N/A unittest main