Module Import alias ImportFrom alias Import alias FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr If CompareEq NameLoad Str body Assign NameStore AttributeLoad NameLoad attr orelse If CompareEq NameLoad Str body Assign NameStore AttributeLoad NameLoad attr Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore Call AttributeLoad NameLoad attr Str Dict Str Str Str Num Num Num keyword NameLoad keyword Str Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr Assert CompareNotEq NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Num Assert CompareEq SubscriptLoad AttributeLoad Call AttributeLoad Call NameLoad NameLoad attr attr Index Str Num decorator_list Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad Str ListLoad ListLoad Str ListLoad Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Expr Str ImportFrom alias Expr Call AttributeLoad NameLoad attr Assign NameStore IfExp CompareIsNot NameLoad NameLoad NameLoad Num Assign NameStore Lambda arguments args defaults ListComp NameLoad comprehension NameStore Call AttributeLoad AttributeLoad NameLoad attr attr CompareNotEq Call AttributeLoad NameLoad attr Str Str Assert CompareEq Call NameLoad Call NameLoad Num Assign NameStore Dict Str Str Str NameLoad If NameLoad body AugAssignAdd SubscriptStore NameLoad Index Str BinOpMod Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad For NameStore Call NameLoad Num NameLoad body Expr Call AttributeLoad NameLoad attr Str BinOpMult ListLoad Dict Str NameLoad NameLoad Assert CompareEq Call NameLoad Call NameLoad NameLoad Expr Call AttributeLoad NameLoad attr keyword NameLoad Assert CompareEq Call NameLoad Call NameLoad Num Expr Call AttributeLoad NameLoad attr decorator_list Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad Str Str Str Str ListLoad TupleLoad NameLoad NameLoad Num Num TupleLoad NameLoad NameLoad Num Num TupleLoad NameLoad Num Num Num TupleLoad NameLoad Num Num Num TupleLoad NameLoad Num Num Num TupleLoad NameLoad Num Num Num TupleLoad Num NameLoad Num Num TupleLoad Num NameLoad Num Num TupleLoad Num Num Num Num TupleLoad Num Num Num Num
N/A N/A time mrq.job Job N/A pytest test_disconnects_service_during_task N/A N/A worker p_service N/A N/A N/A  Test what happens when mongodb disconnects during a job
     N/A N/A N/A worker start N/A N/A p_service mongodb N/A N/A service N/A worker fixture_mongodb N/A N/A N/A p_service redis N/A N/A service N/A worker fixture_redis N/A service_pid N/A N/A service process pid N/A job_id1 N/A N/A worker send_task tests.tasks.general.Add N/A a b sleep 41 1 5 block False queue default N/A N/A N/A time sleep 2 N/A N/A N/A service stop N/A N/A N/A service start N/A service_pid2 N/A N/A service process pid N/A N/A service_pid service_pid2 N/A N/A N/A time sleep 5 N/A N/A N/A N/A N/A N/A N/A Job job_id1 fetch data N/A result 42 N/A N/A N/A N/A pytest mark parametrize N/A p_service N/A N/A mongodb N/A redis test_redis_disconnections N/A N/A gevent_count subpool_size iterations expected_clients worker N/A N/A N/A  mrq.context.connections is not the actual connections pool that the worker uses.
        this worker's pool is not accessible from here, since it runs in a different thread.
     mrq.context connections N/A N/A N/A worker start_deps N/A gevent_count N/A N/A gevent_count None gevent_count 1 N/A get_clients N/A N/A N/A N/A N/A c N/A c N/A N/A N/A connections redis client_list N/A N/A N/A c get cmd client N/A N/A N/A len N/A get_clients 0 N/A kwargs N/A flags deps --redis_max_connections 100 False N/A gevent_count N/A N/A N/A kwargs N/A flags N/A  --gevent %s gevent_count N/A N/A N/A worker start kwargs N/A i N/A range 0 iterations N/A N/A N/A N/A worker send_tasks tests.tasks.redis.Disconnections N/A N/A N/A subpool_size subpool_size gevent_count N/A N/A N/A len N/A get_clients expected_clients N/A N/A N/A worker stop deps False N/A N/A N/A len N/A get_clients 0 N/A N/A N/A worker stop_deps N/A N/A N/A N/A pytest mark parametrize N/A gevent_count subpool_size iterations expected_clients N/A N/A None None 1 1 N/A None None 2 1 N/A None 10 1 10 N/A None 10 2 10 N/A None 200 1 100 N/A None 200 2 100 N/A 4 None 1 4 N/A 4 None 2 4 N/A 2 2 1 4 N/A 2 2 2 4