|
|
@ -10,6 +10,9 @@ import signal
|
|
|
|
import time
|
|
|
|
import time
|
|
|
|
from multiprocessing import Process
|
|
|
|
from multiprocessing import Process
|
|
|
|
import subprocess
|
|
|
|
import subprocess
|
|
|
|
|
|
|
|
import sys
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import pytest
|
|
|
|
|
|
|
|
|
|
|
|
import mock
|
|
|
|
import mock
|
|
|
|
|
|
|
|
|
|
|
@ -748,6 +751,7 @@ class TestWorkerSubprocess(RQTestCase):
|
|
|
|
assert q.count == 0
|
|
|
|
assert q.count == 0
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@pytest.mark.skipif(sys.platform == 'darwin', reason='requires Linux signals')
|
|
|
|
class HerokuWorkerShutdownTestCase(TimeoutTestCase, RQTestCase):
|
|
|
|
class HerokuWorkerShutdownTestCase(TimeoutTestCase, RQTestCase):
|
|
|
|
def setUp(self):
|
|
|
|
def setUp(self):
|
|
|
|
super(HerokuWorkerShutdownTestCase, self).setUp()
|
|
|
|
super(HerokuWorkerShutdownTestCase, self).setUp()
|
|
|
|