<s> import six <EOL> def addjob ( dq , ** kwargs ) : <EOL> def inner ( ) : <EOL> dq . addjob ( ** kwargs ) <EOL> return inner <EOL> def getjob ( dq , ** kwargs ) : <EOL> def inner ( ) : <EOL> dq . getjob ( ** kwargs ) <EOL> return inner <EOL> def test_addjob_benchmarks ( dq , benchmark ) : <EOL> qname = '<STR_LIT>' <EOL> assert dq . getjob ( qname , timeout_ms = <NUM_LIT:1> ) is None <EOL> benchmark ( addjob ( dq , queue = qname , body = '<STR_LIT:foo>' ) ) <EOL> assert dq . qlen ( qname ) <EOL> def test_addjob_no_replicate_bench ( dq , benchmark ) : <EOL> qname = '<STR_LIT>' <EOL> assert dq . getjob ( qname , timeout_ms = <NUM_LIT:1> ) is None <EOL> benchmark ( addjob ( dq , queue = qname , body = '<STR_LIT:foo>' , replicate = <NUM_LIT:1> ) ) <EOL> assert dq . qlen ( qname ) <EOL> def test_addjob_async_bench ( dq , benchmark ) : <EOL> qname = '<STR_LIT>' <EOL> assert dq . getjob ( qname , timeout_ms = <NUM_LIT:1> ) is None <EOL> benchmark ( addjob ( dq , queue = qname , body = '<STR_LIT:foo>' , async = True ) ) <EOL> assert dq . qlen ( qname ) <EOL> def test_getjob_bench ( dq , benchmark ) : <EOL> qname = '<STR_LIT>' <EOL> assert dq . getjob ( qname , timeout_ms = <NUM_LIT:1> ) is None <EOL> for _ in six . moves . range ( <NUM_LIT> ) : <EOL> dq . addjob ( queue = qname , body = '<STR_LIT:foo>' ) <EOL> benchmark ( getjob ( dq , queue = qname , timeout_ms = <NUM_LIT:1> ) ) </s>
