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.}