Skip to content

Commit 818dfad

Browse files
committed
remove forks
1 parent 68575c7 commit 818dfad

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

tests/integrations/ray/test_ray.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,12 @@
1010
from tests.conftest import TestTransport
1111

1212

13+
@pytest.fixture(autouse=True)
14+
def shutdown_ray(tmpdir):
15+
yield
16+
ray.shutdown()
17+
18+
1319
class RayTestTransport(TestTransport):
1420
def __init__(self):
1521
self.envelopes = []
@@ -58,7 +64,6 @@ def read_error_from_log(job_id):
5864
return error
5965

6066

61-
@pytest.mark.forked
6267
@pytest.mark.parametrize(
6368
"task_options", [{}, {"num_cpus": 0, "memory": 1024 * 1024 * 10}]
6469
)
@@ -124,7 +129,6 @@ def example_task():
124129
)
125130

126131

127-
@pytest.mark.forked
128132
def test_errors_in_ray_tasks():
129133
setup_sentry_with_logging_transport()
130134

@@ -157,7 +161,6 @@ def example_task():
157161
assert not error["exception"]["values"][0]["mechanism"]["handled"]
158162

159163

160-
@pytest.mark.forked
161164
def test_tracing_in_ray_actors():
162165
setup_sentry()
163166

@@ -194,7 +197,6 @@ def increment(self):
194197
assert worker_envelopes == []
195198

196199

197-
@pytest.mark.forked
198200
def test_errors_in_ray_actors():
199201
setup_sentry_with_logging_transport()
200202

0 commit comments

Comments
 (0)