|
@@ -15,6 +15,8 @@ import string
|
|
from functools import partial
|
|
from functools import partial
|
|
from time import sleep
|
|
from time import sleep
|
|
|
|
|
|
|
|
+import pytest
|
|
|
|
+
|
|
from taipy.config import Config
|
|
from taipy.config import Config
|
|
from taipy.config.common.scope import Scope
|
|
from taipy.config.common.scope import Scope
|
|
from taipy.core._orchestrator._orchestrator import _Orchestrator
|
|
from taipy.core._orchestrator._orchestrator import _Orchestrator
|
|
@@ -45,6 +47,7 @@ def mult_by_2(n):
|
|
return n * 2
|
|
return n * 2
|
|
|
|
|
|
|
|
|
|
|
|
+@pytest.mark.skip(reason="Too long")
|
|
def test_submit_task_multithreading_multiple_task():
|
|
def test_submit_task_multithreading_multiple_task():
|
|
Config.configure_job_executions(mode=JobConfig._STANDALONE_MODE, max_nb_of_workers=2)
|
|
Config.configure_job_executions(mode=JobConfig._STANDALONE_MODE, max_nb_of_workers=2)
|
|
|
|
|
|
@@ -97,6 +100,7 @@ def test_submit_task_multithreading_multiple_task():
|
|
assert _SubmissionManager._get(job_2.submit_id).submission_status == SubmissionStatus.COMPLETED
|
|
assert _SubmissionManager._get(job_2.submit_id).submission_status == SubmissionStatus.COMPLETED
|
|
|
|
|
|
|
|
|
|
|
|
+@pytest.mark.skip(reason="Too long")
|
|
def test_submit_submittable_multithreading_multiple_task():
|
|
def test_submit_submittable_multithreading_multiple_task():
|
|
Config.configure_job_executions(mode=JobConfig._STANDALONE_MODE, max_nb_of_workers=2)
|
|
Config.configure_job_executions(mode=JobConfig._STANDALONE_MODE, max_nb_of_workers=2)
|
|
|
|
|
|
@@ -143,6 +147,7 @@ def test_submit_submittable_multithreading_multiple_task():
|
|
)
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
+@pytest.mark.skip(reason="Too long")
|
|
def test_submit_task_multithreading_multiple_task_in_sync_way_to_check_job_status():
|
|
def test_submit_task_multithreading_multiple_task_in_sync_way_to_check_job_status():
|
|
Config.configure_job_executions(mode=JobConfig._STANDALONE_MODE, max_nb_of_workers=2)
|
|
Config.configure_job_executions(mode=JobConfig._STANDALONE_MODE, max_nb_of_workers=2)
|
|
|
|
|
|
@@ -225,6 +230,7 @@ def test_submit_task_multithreading_multiple_task_in_sync_way_to_check_job_statu
|
|
assert _SubmissionManager._get(job_2.submit_id).submission_status == SubmissionStatus.COMPLETED
|
|
assert _SubmissionManager._get(job_2.submit_id).submission_status == SubmissionStatus.COMPLETED
|
|
|
|
|
|
|
|
|
|
|
|
+@pytest.mark.skip(reason="Too long")
|
|
def test_blocked_task():
|
|
def test_blocked_task():
|
|
Config.configure_job_executions(mode=JobConfig._STANDALONE_MODE, max_nb_of_workers=2)
|
|
Config.configure_job_executions(mode=JobConfig._STANDALONE_MODE, max_nb_of_workers=2)
|
|
|
|
|
|
@@ -290,6 +296,7 @@ def test_blocked_task():
|
|
)
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
+@pytest.mark.skip(reason="Too long")
|
|
def test_blocked_submittable():
|
|
def test_blocked_submittable():
|
|
Config.configure_job_executions(mode=JobConfig._STANDALONE_MODE, max_nb_of_workers=2)
|
|
Config.configure_job_executions(mode=JobConfig._STANDALONE_MODE, max_nb_of_workers=2)
|
|
|
|
|