Module Import alias Import alias Import alias Import alias Import alias ImportFrom alias alias Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr SubscriptLoad AttributeLoad NameLoad attr Index Num AttributeLoad NameLoad attr AttributeLoad NameLoad attr If Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Str body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Num NameLoad ImportFrom alias alias ImportFrom alias Import alias identifier ImportFrom alias Assign NameStore Dict Assign NameStore NameLoad Expr Call AttributeLoad NameLoad attr Str Assign NameStore Num Assign NameStore NameLoad FunctionDef arguments args defaults body Return Call AttributeLoad NameLoad attr Str keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body For NameStore Call AttributeLoad NameLoad attr body If Call AttributeLoad NameLoad attr Str NameLoad body Assign NameStore SubscriptLoad NameLoad Index Str Assign TupleStore NameStore NameStore Call AttributeLoad NameLoad attr NameLoad For NameStore Call AttributeLoad Call AttributeLoad NameLoad attr Str attr body Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad keyword NameLoad keyword Num keyword NameLoad keyword AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad Assign SubscriptStore NameLoad Index TupleLoad NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore SubscriptLoad NameLoad Index Str If BoolOpOr UnaryOpNot SubscriptLoad NameLoad Index Str CompareIs NameLoad NameLoad body Return NameLoad Return Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad Call AttributeLoad NameLoad attr attr Str NameLoad Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore BinOpSub Call AttributeLoad AttributeLoad NameLoad attr attr SubscriptLoad NameLoad Index Str If CompareGt NameLoad Call AttributeLoad NameLoad attr keyword NameLoad body Expr Call AttributeLoad NameLoad attr Return NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad If Call NameLoad NameLoad body If Call NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr BinOpMod Str TupleLoad SubscriptLoad NameLoad Index Str SubscriptLoad SubscriptLoad NameLoad Index Str Index Str SubscriptLoad NameLoad Index Str orelse Return NameLoad Assign NameStore SubscriptLoad NameLoad Index Str Assign SubscriptStore NameLoad Index Str Call AttributeLoad AttributeLoad NameLoad attr attr Assign SubscriptStore NameLoad Index Str Num Assign SubscriptStore NameLoad Index Str Num Assign NameStore TupleLoad SubscriptLoad NameLoad Index Str SubscriptLoad NameLoad Index Str SubscriptLoad NameLoad Index Str NameLoad Assign NameStore Call NameLoad keyword AttributeLoad NameLoad attr keyword NameLoad Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str NameLoad Expr Call AttributeLoad NameLoad attr BinOpMod Str TupleLoad SubscriptLoad NameLoad Index Str SubscriptLoad SubscriptLoad NameLoad Index Str Index Str SubscriptLoad NameLoad Index Str Return NameLoad decorator_list FunctionDef arguments args defaults body For NameStore Call NameLoad Call AttributeLoad NameLoad attr body If NameLoad body Expr Call NameLoad SubscriptLoad NameLoad Index NameLoad decorator_list FunctionDef arguments args defaults body Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr For NameStore NameLoad body Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index NameLoad Index Str If CompareIsNot NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr For NameStore NameLoad body Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index NameLoad Index Str If CompareIsNot NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr Assign SubscriptStore SubscriptLoad NameLoad Index NameLoad Index Str NameLoad Assign SubscriptStore SubscriptLoad NameLoad Index NameLoad Index Str Num decorator_list FunctionDef arguments args NameParam NameParam defaults body Global identifier Assign NameStore NameLoad Expr Call NameLoad decorator_list If CompareEq NameLoad Str body Assign NameStore Call NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Expr Call NameLoad NameLoad Expr Call NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Str While NameLoad body Expr Call NameLoad Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr Str Expr Call NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Num
N/A N/A datetime N/A os N/A signal N/A sys N/A time multiprocessing Process Manager N/A POSSIBLE_TOPDIR N/A N/A N/A os path normpath N/A N/A N/A os path join N/A N/A N/A os path abspath N/A N/A sys argv N/A 0 N/A os pardir N/A os pardir N/A N/A N/A N/A os path exists N/A N/A N/A os path join POSSIBLE_TOPDIR stacktach N/A N/A N/A N/A N/A sys path insert 0 POSSIBLE_TOPDIR stacktach db stacklog django.db close_connection N/A worker.worker worker worker config N/A processes N/A N/A log_listener None N/A N/A N/A stacklog set_default_logger_name worker N/A DEFAULT_PROC_TIMEOUT 600 N/A RUNNING True _get_parent_logger N/A N/A N/A N/A N/A N/A N/A stacklog get_logger worker is_parent True N/A create_proc_table N/A N/A manager N/A N/A N/A deployment N/A N/A config deployments N/A N/A N/A N/A deployment get enabled True N/A N/A name N/A deployment N/A name N/A N/A db_deployment new N/A N/A db get_or_create_deployment name N/A exchange N/A N/A N/A N/A deployment get topics keys N/A N/A stats N/A N/A manager dict N/A proc_info N/A dict process None pid 0 deployment deployment deploy_id N/A db_deployment id exchange exchange stats stats N/A N/A processes N/A N/A name exchange proc_info N/A is_alive N/A N/A proc_info N/A N/A N/A process N/A proc_info N/A process N/A N/A N/A N/A proc_info N/A pid N/A process None N/A N/A False N/A N/A N/A process is_alive N/A needs_restart N/A N/A proc_info N/A N/A N/A timeout N/A N/A N/A N/A config workers get process_timeout DEFAULT_PROC_TIMEOUT N/A process N/A proc_info N/A process N/A stats N/A proc_info N/A stats N/A age N/A N/A N/A N/A datetime datetime utcnow N/A stats N/A timestamp N/A N/A age N/A N/A datetime timedelta seconds timeout N/A N/A N/A N/A process terminate N/A True N/A False N/A start_proc N/A N/A proc_info N/A N/A N/A logger N/A _get_parent_logger N/A N/A is_alive proc_info N/A N/A N/A needs_restart proc_info N/A N/A N/A N/A logger warning N/A Child process %s (%s %s) terminated due to heartbeat timeout. Restarting... N/A N/A proc_info N/A pid N/A N/A proc_info N/A deployment N/A name N/A proc_info N/A exchange N/A N/A False N/A stats N/A proc_info N/A stats N/A N/A stats N/A timestamp N/A N/A N/A datetime datetime utcnow N/A N/A stats N/A total_processed 0 N/A N/A stats N/A processed 0 N/A args N/A N/A proc_info N/A deployment N/A proc_info N/A deploy_id N/A proc_info N/A exchange stats N/A process N/A Process target N/A worker run args args N/A N/A process daemon True N/A N/A N/A process start N/A N/A proc_info N/A pid N/A process pid N/A N/A proc_info N/A process process N/A N/A N/A logger info N/A Started child process %s (%s %s) N/A N/A proc_info N/A pid N/A N/A proc_info N/A deployment N/A name N/A proc_info N/A exchange N/A True N/A check_or_start_all N/A N/A N/A N/A N/A proc_name N/A sorted N/A N/A processes keys N/A N/A RUNNING N/A N/A N/A start_proc N/A processes N/A proc_name N/A stop_all N/A N/A N/A N/A N/A procs N/A sorted N/A N/A processes keys N/A pname procs N/A N/A process N/A N/A processes N/A pname N/A process N/A N/A process None N/A N/A N/A N/A process terminate N/A pname procs N/A N/A process N/A N/A processes N/A pname N/A process N/A N/A process None N/A N/A N/A N/A process join N/A N/A N/A processes N/A pname N/A process None N/A N/A N/A processes N/A pname N/A pid 0 N/A kill_time N/A N/A signal frame N/A N/A N/A RUNNING N/A RUNNING False N/A N/A stop_all N/A N/A N/A __name__ __main__ N/A N/A logger N/A _get_parent_logger N/A log_listener N/A N/A stacklog LogListener logger N/A N/A N/A log_listener start N/A manager N/A Manager N/A N/A create_proc_table manager N/A N/A close_connection N/A N/A N/A signal signal N/A signal SIGINT kill_time N/A N/A N/A signal signal N/A signal SIGTERM kill_time N/A N/A N/A logger info Starting Workers... N/A RUNNING N/A N/A N/A check_or_start_all N/A N/A N/A time sleep 30 N/A N/A N/A logger info Workers Shutting down... N/A N/A stop_all N/A N/A N/A log_listener end N/A N/A N/A sys exit 0