Skip to content

Commit f19187b

Browse files
committed
fix: remove mock
1 parent e021617 commit f19187b

1 file changed

Lines changed: 10 additions & 6 deletions

File tree

tests/test_concurrency.py

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -42,14 +42,18 @@ def fake_bootstrap_run(handler, lambda_runtime_client):
4242
), patch(
4343
"awslambdaric.lambda_multi_concurrent_utils.bootstrap.run",
4444
side_effect=fake_bootstrap_run,
45-
), patch(
46-
"awslambdaric.lambda_multi_concurrent_utils.multiprocessing.Process",
47-
threading.Thread,
4845
):
4946
# spawn 4 multi-concurrent processes
50-
MultiConcurrentRunner.run_concurrent(
51-
self.handler, self.addr, self.use_thread, self.socket, max_concurrency=4
52-
)
47+
threads = []
48+
for _ in range(4):
49+
t = threading.Thread(
50+
target=MultiConcurrentRunner.run_single,
51+
args=(self.handler, self.addr, self.use_thread, self.socket),
52+
)
53+
t.start()
54+
threads.append(t)
55+
for t in threads:
56+
t.join()
5357

5458
self.assertEqual(success_counter, 6)
5559
self.assertEqual(fail_counter, 2)

0 commit comments

Comments
 (0)