def METHOD_NAME():
    _explode_pid["pid"] = os.getpid()
    with instance_for_test() as instance:
        run_config = {
            "ops": {"op_that_uses_adder_resource": {"inputs": {"number": {"value": 4}}}},
        }
        execution_plan = create_execution_plan(
            job_with_resources,
            run_config,
        )
        dagster_run = instance.create_run_for_job(
            job_def=job_with_resources,
            execution_plan=execution_plan,
            run_config=run_config,
        )
        recon_job = reconstructable(job_with_resources)
        execute_run_host_mode(
            ExplodingTestPipeline(recon_job.repository, recon_job.job_name),
            dagster_run,
            instance,
            executor_defs=[test_executor],
            raise_on_error=True,
        )
        assert instance.get_run_by_id(dagster_run.run_id).status == DagsterRunStatus.SUCCESS
        logs = instance.all_logs(dagster_run.run_id)
        assert any(
            e.is_dagster_event and "Executing steps using multiprocess executor" in e.message
            for e in logs
        )