Skip to content

Commit d7c9422

Browse files
committed
fix require_beam
1 parent f117919 commit d7c9422

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

tests/utils.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,10 @@ def parse_flag_from_env(key, default=False):
7676
)
7777

7878
# Beam
79-
require_beam = pytest.mark.skipif(not config.BEAM_AVAILABLE, reason="test requires apache-beam")
79+
require_beam = pytest.mark.skipif(
80+
not config.BEAM_AVAILABLE or config.DILL_VERSION.release >= version.parse("0.3.6"),
81+
reason="test requires apache-beam and a compatible dill version",
82+
)
8083

8184

8285
def require_faiss(test_case):

0 commit comments

Comments
 (0)