We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f9e566f commit 8c873b0Copy full SHA for 8c873b0
1 file changed
tests/test_forking.py
@@ -3,13 +3,16 @@
3
4
from sqlmesh import Context
5
from sqlmesh.core.model import schema
6
+import multiprocessing as mp
7
8
9
pytestmark = pytest.mark.isolated
10
11
12
def test_parallel_load(assert_exp_eq, mocker):
- mocker.patch("sqlmesh.core.constants.MAX_FORK_WORKERS", 2)
13
+ if hasattr(os, "fork") and not mp.current_process().daemon:
14
+ mocker.patch("sqlmesh.core.constants.MAX_FORK_WORKERS", 2)
15
+
16
spy = mocker.spy(schema, "_update_model_schemas")
17
context = Context(paths="examples/sushi")
18
0 commit comments