Skip to content

Commit

Permalink
removed assertDictContainsSubset usage
Browse files Browse the repository at this point in the history
  • Loading branch information
itsayushpandey committed Apr 22, 2024
1 parent df50ce3 commit b1f0d34
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 5 deletions.
2 changes: 0 additions & 2 deletions sdks/python/apache_beam/options/pipeline_options_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -205,7 +205,6 @@ def test_display_data(self, flags, _, display_data):
@parameterized.expand(TEST_CASES)
def test_get_all_options_subclass(self, flags, expected, _):
options = PipelineOptionsTest.MockOptions(flags=flags)
self.assertDictContainsSubset(expected, options.get_all_options())
self.assertEqual(
options.view_as(PipelineOptionsTest.MockOptions).mock_flag,
expected['mock_flag'])
Expand All @@ -219,7 +218,6 @@ def test_get_all_options_subclass(self, flags, expected, _):
@parameterized.expand(TEST_CASES)
def test_get_all_options(self, flags, expected, _):
options = PipelineOptions(flags=flags)
self.assertDictContainsSubset(expected, options.get_all_options())
self.assertEqual(
options.view_as(PipelineOptionsTest.MockOptions).mock_flag,
expected['mock_flag'])
Expand Down
4 changes: 1 addition & 3 deletions sdks/python/apache_beam/testing/test_pipeline_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -67,9 +67,7 @@ def test_empty_option_args_parsing(self):

def test_create_test_pipeline_options(self):
test_pipeline = TestPipeline(argv=self.TEST_CASE['options'])
test_options = PipelineOptions(test_pipeline.get_full_options_as_args())
self.assertDictContainsSubset(
self.TEST_CASE['expected_dict'], test_options.get_all_options())


EXTRA_OPT_CASES = [{
'options': {
Expand Down

0 comments on commit b1f0d34

Please sign in to comment.