Skip to content

Commit 7659fa2

Browse files
committed
Import dill for test
1 parent 6077034 commit 7659fa2

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

sdks/python/apache_beam/transforms/ptransform_test.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -728,13 +728,15 @@ def test_flatten_one_single_pcollection(self):
728728
param(compat_version="2.66.0"),
729729
])
730730
@pytest.mark.it_validatesrunner
731+
@pytest.mark.uses_dill
731732
def test_group_by_key_importable_special_types(self, compat_version):
732733
def generate(_):
733734
for _ in range(100):
734735
yield (coders_test_common.MyTypedNamedTuple(1, 'a'), 1)
735736

736737
pipeline = TestPipeline(is_integration_test=True)
737738
if compat_version:
739+
pytest.importorskip("dill")
738740
pipeline.get_pipeline_options().view_as(
739741
StreamingOptions).update_compatibility_version = compat_version
740742
with pipeline as p:

0 commit comments

Comments
 (0)