Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 4 additions & 1 deletion awslambdaric/__main__.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@

from .lambda_config import LambdaConfigProvider
from .lambda_runtime_client import LambdaRuntimeClient
from .lambda_multi_concurrent_utils import MultiConcurrentRunner
from . import bootstrap


Expand All @@ -20,6 +19,10 @@ def main(args):
# Multi-concurrent mode: redirect fork, stdout/stderr and run
max_conc = int(config.max_concurrency)
socket_path = config.lmi_socket_path

# Importing multi_concurrent_utils only in the multiconcurrent path
Comment thread
darklight3it marked this conversation as resolved.
Outdated
from .lambda_multi_concurrent_utils import MultiConcurrentRunner
Comment thread
darklight3it marked this conversation as resolved.

MultiConcurrentRunner.run_concurrent(
handler, api_addr, use_thread, socket_path, max_conc
)
Expand Down
2 changes: 1 addition & 1 deletion tests/test_main.py
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ def test_default_path_invokes_runtime_client_and_bootstrap(
"my.handler", mock_client_cls.return_value
)

@patch("awslambdaric.__main__.MultiConcurrentRunner")
@patch("awslambdaric.lambda_multi_concurrent_utils.MultiConcurrentRunner")
@patch("awslambdaric.__main__.LambdaConfigProvider")
def test_multi_concurrent_path_dispatches_to_multi_concurrent_runner(
self, mock_config_provider, mock_runner
Expand Down
Loading