Module Import alias Import alias ImportFrom alias alias ImportFrom alias alias ImportFrom alias ImportFrom alias alias ImportFrom alias alias ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign NameStore Call NameLoad NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign TupleStore AttributeStore NameLoad attr AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Return AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body With AttributeLoad NameLoad attr body If CompareIsNot AttributeLoad NameLoad attr NameLoad body TryExcept body With Call AttributeLoad NameLoad attr keyword Str AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameStore body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr handlers ExceptHandler type AttributeLoad NameLoad attr body Pass Return NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Str TryExcept body Expr Call AttributeLoad NameLoad attr keyword Str handlers ExceptHandler type AttributeLoad NameLoad attr body Pass TryFinally body TryExcept body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str TryFinally body With AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr With Call AttributeLoad AttributeLoad NameLoad attr attr body Assign SubscriptStore AttributeLoad AttributeLoad NameLoad attr attr Index Str AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr finalbody With AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr NameLoad With Call AttributeLoad AttributeLoad NameLoad attr attr body Assign SubscriptStore AttributeLoad AttributeLoad NameLoad attr attr Index Str NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr handlers ExceptHandler type AttributeLoad NameLoad attr name NameStore body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Call NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Call NameLoad Call NameLoad NameLoad ExceptHandler type AttributeLoad NameLoad attr name NameStore body Assign TupleStore NameStore NameStore AttributeLoad NameLoad attr Assign NameStore BinOpMod Str TupleLoad NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad NameLoad attr NameLoad ExceptHandler type NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str finalbody Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr SubscriptLoad Call AttributeLoad NameLoad attr Index Num decorator_list decorator_list
N/A N/A _mysql N/A sys threading Thread Lock memsql_loader.db connection_wrapper pool memsql_loader.db.load_data LoadDataStmt memsql_loader.util db_utils log memsql_loader.execution.errors WorkerException ConnectionException Loader N/A Thread N/A load N/A N/A self job task fifo db_connection N/A N/A N/A N/A self _job job N/A N/A self _task task N/A N/A self _fifo fifo N/A N/A self _conn db_connection N/A load_data N/A LoadDataStmt job N/A task file_id N/A fifo path N/A N/A N/A self _sql N/A self _params N/A N/A load_data build N/A N/A self _error None N/A N/A self _tb None N/A N/A self _active_conn_id None N/A N/A self _conn_lock N/A Lock N/A N/A N/A N/A self _fifo attach_reader N/A self abort N/A error N/A N/A self N/A N/A N/A N/A self _error N/A property traceback N/A N/A self N/A N/A N/A N/A self _tb N/A property abort N/A N/A self N/A N/A N/A N/A self _conn_lock N/A N/A N/A N/A self _active_conn_id None N/A N/A N/A N/A N/A N/A pool get_connection database N/A N/A N/A self _job spec connection conn N/A N/A N/A N/A db_utils try_kill_connection conn N/A self _active_conn_id N/A N/A N/A N/A pool PoolConnectionException N/A N/A N/A True N/A False N/A run N/A N/A self N/A N/A N/A N/A self logger N/A N/A log get_logger loader N/A N/A N/A N/A N/A _mysql connect unix_socket . N/A N/A N/A N/A _mysql MySQLError N/A N/A N/A N/A N/A N/A N/A N/A N/A N/A self logger info Starting loader N/A N/A N/A N/A self _conn_lock N/A N/A N/A self _active_conn_id N/A N/A N/A self _conn thread_id N/A N/A N/A N/A self _task protect N/A N/A N/A N/A N/A self _task data N/A conn_id N/A self _active_conn_id N/A N/A N/A N/A self _task save N/A row_count N/A N/A N/A self _conn query N/A self _sql N/A self _params N/A N/A N/A self _conn_lock N/A N/A N/A self _active_conn_id None N/A N/A N/A N/A self _task protect N/A N/A N/A N/A N/A self _task data N/A row_count row_count N/A N/A N/A N/A self _task save N/A N/A N/A N/A connection_wrapper ConnectionWrapperException N/A e N/A N/A N/A N/A N/A self logger error LOAD DATA connection error: %s N/A str e N/A N/A N/A self _set_error N/A ConnectionException N/A str e N/A N/A N/A pool MySQLError N/A e N/A N/A N/A errno msg N/A e args N/A msg N/A LOAD DATA error (%d): %s N/A errno msg N/A N/A N/A N/A self logger error msg N/A N/A N/A self _set_error N/A WorkerException msg N/A N/A Exception N/A e N/A N/A N/A N/A self _set_error e N/A N/A KeyboardInterrupt N/A N/A N/A N/A N/A self logger info Received KeyboardInterrupt, exiting... N/A N/A N/A N/A N/A self _fifo detach_reader N/A N/A N/A N/A self logger info Finished LOAD_DATA N/A _set_error N/A N/A self err N/A N/A N/A N/A self _error err N/A N/A self _tb N/A N/A N/A sys exc_info N/A 2 N/A N/A