mirror of
https://github.com/planetmint/planetmint.git
synced 2025-03-30 15:08:31 +00:00
fixed refactoring issues
Signed-off-by: Jürgen Eckel <juergen@riddleandcode.com>
This commit is contained in:
parent
8943f2066b
commit
2482c139cd
@ -14,7 +14,7 @@ import gunicorn.app.base
|
||||
|
||||
from flask import Flask
|
||||
from flask_cors import CORS
|
||||
from planetmint import utils
|
||||
from planetmint.utils import processes
|
||||
from planetmint.application.validator import Validator
|
||||
from planetmint.web.routes import add_routes
|
||||
from planetmint.web.strip_content_type_middleware import StripContentTypeMiddleware
|
||||
@ -81,7 +81,7 @@ def create_app(*, debug=False, threads=1, planetmint_factory=None):
|
||||
|
||||
app.debug = debug
|
||||
|
||||
app.config["validator_class_name"] = utils.pool(planetmint_factory, size=threads)
|
||||
app.config["validator_class_name"] = processes.pool(planetmint_factory, size=threads)
|
||||
|
||||
add_routes(app)
|
||||
|
||||
|
@ -7,6 +7,7 @@ import queue
|
||||
import pytest
|
||||
|
||||
from unittest.mock import patch, call
|
||||
from planetmint.utils import processes
|
||||
|
||||
|
||||
@pytest.fixture
|
||||
@ -32,9 +33,7 @@ def mock_queue(monkeypatch):
|
||||
|
||||
|
||||
def test_empty_pool_is_populated_with_instances(mock_queue):
|
||||
from planetmint import utils
|
||||
|
||||
pool = utils.pool(lambda: "hello", 4)
|
||||
pool = processes.pool(lambda: "hello", 4)
|
||||
|
||||
assert len(mock_queue.items) == 0
|
||||
|
||||
@ -60,9 +59,7 @@ def test_empty_pool_is_populated_with_instances(mock_queue):
|
||||
|
||||
|
||||
def test_pool_blocks_if_no_instances_available(mock_queue):
|
||||
from planetmint import utils
|
||||
|
||||
pool = utils.pool(lambda: "hello", 4)
|
||||
pool = processes.pool(lambda: "hello", 4)
|
||||
|
||||
assert len(mock_queue.items) == 0
|
||||
|
||||
@ -98,9 +95,7 @@ def test_pool_blocks_if_no_instances_available(mock_queue):
|
||||
|
||||
|
||||
def test_pool_raises_empty_exception_when_timeout(mock_queue):
|
||||
from planetmint import utils
|
||||
|
||||
pool = utils.pool(lambda: "hello", 1, timeout=1)
|
||||
pool = processes.pool(lambda: "hello", 1, timeout=1)
|
||||
|
||||
assert len(mock_queue.items) == 0
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user