DNM Add RunWithSubprocess

[chromy]

No description provided.

[codecov]

❌ 1 Tests Failed:

Tests completed	Failed	Passed	Skipped
335	1	334	1

View the top 1 failed test(s) by shortest run time

tests.integration.test_kafka::test_benchmark_job

Stack Traces | 0.006s run time

benchmark = <pytest_benchmark.fixture.BenchmarkFixture object at 0x7f8b7bd7b770>
def test_benchmark_job(benchmark):
log_queue = multiprocessing.Queue()
def do_job():
job = Job(return_hello_world, log_queue, Message(make_value(KafkaPayload(None, None, []))))
while True:
r = job.poll()
if r is not None:
return r
time.sleep(0.01)
> final = benchmark(do_job)
^^^^^^^^^^^^^^^^^
tests/integration/test_kafka.py:209: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ .../local/lib/python3.13....../site-packages/pytest_benchmark/fixture.py:184: in __call__
return self._raw(function_to_benchmark, *args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
.../local/lib/python3.13....../site-packages/pytest_benchmark/fixture.py:248: in _raw
function_result = function_to_benchmark(*args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
tests/integration/test_kafka.py:202: in do_job
job = Job(return_hello_world, log_queue, Message(make_value(KafkaPayload(None, None, []))))
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
.../src/launchpad/kafka.py:70: in __init__
self.__process.start()
.../local/lib/python3.13/multiprocessing/process.py:121: in start
self._popen = self._Popen(self)
^^^^^^^^^^^^^^^^^
.../local/lib/python3.13/multiprocessing/context.py:301: in _Popen
return Popen(process_obj)
^^^^^^^^^^^^^^^^^^
.../local/lib/python3.13/multiprocessing/popen_forkserver.py:35: in __init__
super().__init__(process_obj)
.../local/lib/python3.13/multiprocessing/popen_fork.py:20: in __init__
self._launch(process_obj)
.../local/lib/python3.13/multiprocessing/popen_forkserver.py:47: in _launch
reduction.dump(process_obj, buf)
.../local/lib/python3.13/multiprocessing/reduction.py:60: in dump
ForkingPickler(file, protocol).dump(obj)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ self = <Lock(owner=None)>
def __getstate__(self):
context.assert_spawning(self)
sl = self._semlock
if sys.platform == 'win32':
h = context.get_spawning_popen().duplicate_for_child(sl.handle)
else:
if self._is_fork_ctx:
> raise RuntimeError('A SemLock created in a fork context is being '
'shared with a process in a spawn context. This is '
'not supported. Please use the same context to create '
'multiprocessing objects and Process.')
E RuntimeError: A SemLock created in a fork context is being shared with a process in a spawn context. This is not supported. Please use the same context to create multiprocessing objects and Process.
.../local/lib/python3.13/multiprocessing/synchronize.py:107: RuntimeError

To view more test analytics, go to the Test Analytics Dashboard
_{📋 Got 3 mins? Take this short survey to help us improve Test Analytics.}