Mercurial > repos > shellac > guppy_basecaller
comparison env/lib/python3.7/site-packages/gxformat2/_yaml.py @ 2:6af9afd405e9 draft
"planemo upload commit 0a63dd5f4d38a1f6944587f52a8cd79874177fc1"
author | shellac |
---|---|
date | Thu, 14 May 2020 14:56:58 -0400 |
parents | 26e78fe6e8c4 |
children |
comparison
equal
deleted
inserted
replaced
1:75ca89e9b81c | 2:6af9afd405e9 |
---|---|
1 """YAML loading utilities for gxformat2.""" | |
2 from collections import OrderedDict | |
3 | |
4 try: | |
5 from galaxy.model.custom_types import MutationDict | |
6 except ImportError: | |
7 MutationDict = None | |
8 import yaml | |
9 | |
10 | |
11 def ordered_load(stream, Loader=yaml.SafeLoader, **kwds): | |
12 """Safe and ordered load of YAML from stream.""" | |
13 class OrderedLoader(Loader): | |
14 pass | |
15 | |
16 def construct_mapping(loader, node): | |
17 loader.flatten_mapping(node) | |
18 return OrderedDict(loader.construct_pairs(node)) | |
19 | |
20 OrderedLoader.add_constructor( | |
21 yaml.resolver.BaseResolver.DEFAULT_MAPPING_TAG, | |
22 construct_mapping) | |
23 | |
24 return yaml.load(stream, OrderedLoader, **kwds) | |
25 | |
26 | |
27 def ordered_dump(data, stream=None, Dumper=yaml.SafeDumper, **kwds): | |
28 """Safe and ordered dump of YAML to stream.""" | |
29 class OrderedDumper(Dumper): | |
30 pass | |
31 | |
32 def _dict_representer(dumper, data): | |
33 return dumper.represent_mapping( | |
34 yaml.resolver.BaseResolver.DEFAULT_MAPPING_TAG, | |
35 list(data.items())) | |
36 OrderedDumper.add_representer(OrderedDict, _dict_representer) | |
37 if MutationDict is not None: | |
38 OrderedDumper.add_representer(MutationDict, _dict_representer) | |
39 | |
40 return yaml.dump(data, stream, OrderedDumper, **kwds) | |
41 | |
42 | |
43 __all__ = ( | |
44 'ordered_dump', | |
45 'ordered_load', | |
46 ) |