You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by go...@apache.org on 2021/03/25 18:18:00 UTC
[beam] branch master updated: More flexible GBK tests.
This is an automated email from the ASF dual-hosted git repository.
goenka pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 26030bf More flexible GBK tests.
new e30c349 Merge pull request #14287 from robertwb/gbk-testing
26030bf is described below
commit 26030bfea03fd700560e771571094ff5394dc3bb
Author: Robert Bradshaw <ro...@gmail.com>
AuthorDate: Fri Mar 19 16:49:18 2021 -0700
More flexible GBK tests.
---
sdks/python/apache_beam/transforms/ptransform_test.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/sdks/python/apache_beam/transforms/ptransform_test.py b/sdks/python/apache_beam/transforms/ptransform_test.py
index 2f2bb98..6b35818 100644
--- a/sdks/python/apache_beam/transforms/ptransform_test.py
+++ b/sdks/python/apache_beam/transforms/ptransform_test.py
@@ -35,6 +35,7 @@ from builtins import map
from builtins import range
from builtins import zip
from functools import reduce
+from typing import Iterable
from typing import Optional
from unittest.mock import patch
@@ -2592,6 +2593,8 @@ def _sort_lists(result):
return tuple(_sort_lists(e) for e in result)
elif isinstance(result, dict):
return {k: _sort_lists(v) for k, v in result.items()}
+ elif isinstance(result, Iterable) and not isinstance(result, str):
+ return sorted(result)
else:
return result