|
|
@ -11,6 +11,7 @@ import time
|
|
|
|
from multiprocessing import Process
|
|
|
|
from multiprocessing import Process
|
|
|
|
import subprocess
|
|
|
|
import subprocess
|
|
|
|
import sys
|
|
|
|
import sys
|
|
|
|
|
|
|
|
from unittest import skipIf
|
|
|
|
|
|
|
|
|
|
|
|
import pytest
|
|
|
|
import pytest
|
|
|
|
|
|
|
|
|
|
|
@ -742,6 +743,7 @@ class TestWorkerSubprocess(RQTestCase):
|
|
|
|
assert get_failed_queue().count == 0
|
|
|
|
assert get_failed_queue().count == 0
|
|
|
|
assert q.count == 0
|
|
|
|
assert q.count == 0
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@skipIf('pypy' in sys.version.lower(), 'often times out with pypy')
|
|
|
|
def test_run_scheduled_access_self(self):
|
|
|
|
def test_run_scheduled_access_self(self):
|
|
|
|
"""Schedule a job that schedules a job, then run the worker as subprocess"""
|
|
|
|
"""Schedule a job that schedules a job, then run the worker as subprocess"""
|
|
|
|
q = Queue()
|
|
|
|
q = Queue()
|
|
|
|