Module Import alias Import alias Import alias ImportFrom alias ImportFrom alias alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias alias alias ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign TupleStore AttributeStore NameLoad attr AttributeStore NameLoad attr TupleLoad Call NameLoad Str Call NameLoad Str decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign TupleStore AttributeStore NameLoad attr AttributeStore NameLoad attr TupleLoad Call NameLoad Str Call NameLoad Str Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad NameLoad Str decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign TupleStore AttributeStore NameLoad attr AttributeStore NameLoad attr TupleLoad Call NameLoad Str Call NameLoad Str Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword Str decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad NameLoad Str decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call NameLoad Str Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Str keyword Str decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad NameLoad Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Str decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Num Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Num Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad keyword TupleLoad Num Expr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Str Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Num Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Num Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Num decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign AttributeStore NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Num Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Num Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call NameLoad FunctionDef arguments args NameParam defaults vararg body Return NameLoad decorator_list Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr keyword NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Num Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Num Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Str Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword TupleLoad AttributeLoad NameLoad attr Num keyword Num Expr Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad Expr Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body TryExcept body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad name NameStore body If CompareEq AttributeLoad NameLoad attr Num body Pass decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword TupleLoad Str keyword NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad NameLoad attr Assign NameStore AttributeLoad NameLoad attr handlers ExceptHandler type AttributeLoad NameLoad attr body Assign NameStore NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list Call NameLoad TupleLoad Num Num TupleLoad Num Num TupleLoad Num NameLoad decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword TupleLoad Str keyword Num Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad With Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameStore body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad AttributeLoad NameLoad attr attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr keyword Num keyword Num decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Num decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr keyword Str Assign AttributeStore AttributeLoad NameLoad attr attr Call NameLoad Num Num Num keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword Num decorator_list decorator_list
N/A N/A os N/A time N/A times datetime datetime django.test TransactionTestCase TestCase django.utils.timezone utc nose2.tools params pq Queue pq.queue get_failed_queue pq.worker Worker pq.job Job fixtures say_hello div_by_zero create_file_after_timeout TestWorker N/A TransactionTestCase N/A setUp N/A N/A self N/A N/A N/A N/A N/A self fooq N/A self barq N/A N/A Queue foo N/A Queue bar N/A test_create_worker N/A N/A self N/A N/A N/A Worker creation. N/A w N/A N/A Worker create N/A N/A self fooq N/A self barq N/A N/A N/A self assertEquals N/A w queues N/A N/A self fooq N/A self barq N/A N/A TestWorkNoJobs N/A TransactionTestCase N/A setUp N/A N/A self N/A N/A N/A N/A N/A self fooq N/A self barq N/A N/A Queue foo N/A Queue bar N/A N/A self w N/A N/A Worker create N/A N/A self fooq N/A self barq N/A test_work_no_jobs N/A N/A self N/A N/A N/A N/A N/A self assertEquals N/A N/A N/A self w work burst True False Did not expect any work on the queue. N/A N/A TestWorkerWithJobs N/A TransactionTestCase N/A setUp N/A N/A self N/A N/A N/A N/A N/A self fooq N/A self barq N/A N/A Queue foo N/A Queue bar N/A N/A self w N/A N/A Worker create N/A N/A self fooq N/A self barq N/A N/A N/A N/A self fooq enqueue say_hello name Frank N/A test_worker_with_jobs N/A N/A self N/A N/A N/A N/A N/A self assertEquals N/A N/A N/A self w work burst True True Expected at least some work done. N/A N/A TestWorkViaStringArg N/A TransactionTestCase N/A setUp N/A N/A self N/A N/A N/A N/A self q N/A Queue foo N/A N/A self w N/A N/A Worker create N/A N/A self q N/A N/A self job N/A N/A N/A self q enqueue test_pq.fixtures.say_hello name Frank N/A test_work_via_string_argument N/A N/A self N/A N/A N/A Worker processes work fed via string arguments. N/A N/A N/A self assertEquals N/A N/A N/A self w work burst True True Expected at least some work done. N/A job N/A N/A N/A Job objects get id N/A N/A self job id N/A N/A N/A self assertEquals N/A job result Hi there, Frank! N/A N/A TestWorkIsUnreadable N/A TransactionTestCase N/A setUp N/A N/A self N/A N/A N/A N/A self q N/A Queue N/A N/A N/A N/A self q save N/A N/A self fq N/A get_failed_queue N/A N/A self w N/A N/A Worker create N/A N/A self q N/A test_work_is_unreadable N/A N/A self N/A N/A N/A Unreadable jobs are put on the failed queue. N/A N/A N/A self assertEquals N/A N/A self fq count 0 N/A N/A N/A self assertEquals N/A N/A self q count 0 N/A job N/A N/A Job create func div_by_zero args N/A 3 N/A N/A N/A job save N/A N/A job instance nonexisting_job N/A N/A job queue N/A self q N/A N/A N/A job save N/A N/A N/A self assertEquals N/A N/A self q count 1 N/A N/A N/A N/A self w work burst True N/A N/A N/A self assertEquals N/A N/A self q count 0 N/A N/A N/A self assertEquals N/A N/A self fq count 1 N/A N/A TestWorkFails N/A TransactionTestCase N/A setUp N/A N/A self N/A N/A N/A N/A self q N/A Queue N/A N/A self fq N/A get_failed_queue N/A N/A self w N/A N/A Worker create N/A N/A self q N/A N/A self job N/A N/A N/A self q enqueue div_by_zero N/A N/A self enqueued_at N/A N/A self job enqueued_at N/A test_work_fails N/A N/A self N/A N/A N/A Failing jobs are put on the failed queue. N/A N/A N/A N/A self w work burst True N/A N/A N/A self assertEquals N/A N/A self q count 0 N/A N/A N/A self assertEquals N/A N/A self fq count 1 N/A job N/A N/A N/A Job objects get id N/A N/A self job id N/A N/A N/A self assertEquals N/A job origin N/A N/A self q name N/A N/A N/A self assertEquals N/A job enqueued_at N/A self enqueued_at N/A N/A N/A self assertIsNotNone N/A job exc_info N/A N/A TestWorkerCustomExcHandling N/A TransactionTestCase N/A setUp N/A N/A self N/A N/A N/A N/A self q N/A Queue N/A N/A self fq N/A get_failed_queue black_hole N/A N/A job N/A exc_info N/A N/A False N/A N/A N/A self black_hole black_hole N/A N/A self job N/A N/A N/A self q enqueue div_by_zero N/A test_custom_exc_handling N/A N/A self N/A N/A N/A Custom exception handling. N/A w N/A N/A Worker create N/A N/A self q exc_handler N/A self black_hole N/A N/A N/A w work burst True N/A N/A N/A self assertEquals N/A N/A self q count 0 N/A N/A N/A self assertEquals N/A N/A self fq count 0 N/A job N/A N/A N/A Job objects get id N/A N/A self job id N/A N/A N/A self assertEquals N/A job status N/A Job FAILED N/A N/A TestWorkerTimeouts N/A TransactionTestCase N/A setUp N/A N/A self N/A N/A N/A N/A self sentinel_file /tmp/.rq_sentinel N/A N/A self q N/A Queue N/A N/A self fq N/A get_failed_queue N/A N/A self w N/A N/A Worker create N/A N/A self q N/A test_timeouts N/A N/A self N/A N/A N/A Worker kills jobs after timeout. N/A jobr N/A N/A N/A self q enqueue create_file_after_timeout args N/A N/A self sentinel_file 4 timeout 1 N/A N/A N/A self assertEquals N/A N/A N/A os path exists N/A self sentinel_file False N/A N/A N/A N/A self w work burst True N/A N/A N/A self assertEquals N/A N/A N/A os path exists N/A self sentinel_file False N/A job N/A N/A N/A Job objects get id N/A jobr id N/A N/A N/A self assertIn JobTimeoutException N/A job exc_info N/A tearDown N/A N/A self N/A N/A N/A N/A N/A N/A N/A os unlink N/A self sentinel_file N/A N/A N/A OSError N/A e N/A N/A N/A N/A e errno 2 N/A N/A N/A N/A TestWorkerSetsResultTTL N/A TransactionTestCase N/A setUp N/A N/A self N/A N/A N/A N/A self q N/A Queue N/A N/A self w N/A N/A Worker create N/A N/A self q N/A test_worker_sets_result_ttl N/A N/A self ttl outcome N/A N/A N/A Ensure that Worker properly sets result_ttl for individual jobs or deletes them. N/A job N/A N/A N/A self q enqueue say_hello args N/A Frank result_ttl ttl N/A N/A N/A N/A self w work burst True N/A N/A N/A rjob N/A N/A N/A Job objects get id N/A job id N/A result_ttl N/A rjob result_ttl N/A N/A N/A N/A Job DoesNotExist N/A N/A result_ttl None N/A N/A N/A self assertEqual result_ttl outcome N/A N/A params N/A 10 10 N/A -1 -1 N/A 0 None N/A TestWorkerDeletesExpiredTTL N/A TransactionTestCase N/A setUp N/A N/A self N/A N/A N/A N/A self q N/A Queue N/A N/A self w N/A N/A Worker create N/A N/A self q N/A N/A self job N/A N/A N/A self q enqueue say_hello args N/A Bob result_ttl 1 N/A N/A N/A N/A self w work burst True N/A test_worker_deletes_expired_ttl N/A N/A self N/A N/A N/A Ensure that Worker deletes expired jobs N/A N/A N/A time sleep 1 N/A N/A N/A N/A self w work burst True N/A N/A N/A self assertRaises N/A Job DoesNotExist exc N/A N/A rjob N/A N/A N/A Job objects get id N/A N/A self job id N/A N/A TestWorkerDequeueTimeout N/A TransactionTestCase N/A N/A Simple test to ensure the worker finishes setUp N/A N/A self N/A N/A N/A N/A self q N/A Queue N/A N/A self w N/A N/A Worker create N/A N/A self q expires_after 1 default_worker_ttl 1 N/A test_worker_dequeue_timeout N/A N/A self N/A N/A N/A N/A N/A N/A self w work N/A N/A N/A self assertEqual N/A N/A self w _expires_after -1 N/A N/A TestRegisterHeartbeat N/A TransactionTestCase N/A setUp N/A N/A self N/A N/A N/A N/A self q N/A Queue N/A N/A self w N/A N/A Worker create N/A N/A self q name Test N/A N/A N/A self w heartbeat N/A datetime 2010 1 1 tzinfo utc N/A test_worker_register_heartbeat N/A N/A self N/A N/A N/A N/A N/A N/A self w register_heartbeat timeout 0 N/A N/A