|
37 | 37 | import coloredlogs
|
38 | 38 | import pkg_resources # part of setuptools
|
39 | 39 | import ruamel.yaml
|
| 40 | +from cwl_utils.pack import pack |
40 | 41 | from ruamel.yaml.comments import CommentedMap, CommentedSeq
|
41 | 42 | from ruamel.yaml.main import YAML
|
42 | 43 | from schema_salad.exceptions import ValidationException
|
|
68 | 69 | from .loghandler import _logger, configure_logging, defaultStreamHandler
|
69 | 70 | from .mpi import MpiConfig
|
70 | 71 | from .mutation import MutationManager
|
71 |
| -from .pack import pack |
72 | 72 | from .process import (
|
73 | 73 | CWL_IANA,
|
74 | 74 | Process,
|
@@ -629,16 +629,11 @@ def loadref(base: str, uri: str) -> Union[CommentedMap, CommentedSeq, str, None]
|
629 | 629 |
|
630 | 630 |
|
631 | 631 | def print_pack(
|
632 |
| - loadingContext: LoadingContext, |
633 | 632 | uri: str,
|
634 | 633 | ) -> str:
|
635 | 634 | """Return a CWL serialization of the CWL document in JSON."""
|
636 |
| - packed = pack(loadingContext, uri) |
637 |
| - if len(cast(Sized, packed["$graph"])) > 1: |
638 |
| - return json_dumps(packed, indent=4, default=str) |
639 |
| - return json_dumps( |
640 |
| - cast(MutableSequence[CWLObjectType], packed["$graph"])[0], indent=4, default=str |
641 |
| - ) |
| 635 | + packed = pack(uri) |
| 636 | + return json_dumps(packed, indent=4, default=str) |
642 | 637 |
|
643 | 638 |
|
644 | 639 | def supported_cwl_versions(enable_dev: bool) -> List[str]:
|
@@ -1127,14 +1122,12 @@ def main(
|
1127 | 1122 | processobj, metadata = loadingContext.loader.resolve_ref(uri)
|
1128 | 1123 | processobj = cast(Union[CommentedMap, CommentedSeq], processobj)
|
1129 | 1124 | if args.pack:
|
1130 |
| - print(print_pack(loadingContext, uri), file=stdout) |
| 1125 | + print(print_pack(uri), file=stdout) |
1131 | 1126 | return 0
|
1132 | 1127 |
|
1133 | 1128 | if args.provenance and runtimeContext.research_obj:
|
1134 | 1129 | # Can't really be combined with args.pack at same time
|
1135 |
| - runtimeContext.research_obj.packed_workflow( |
1136 |
| - print_pack(loadingContext, uri) |
1137 |
| - ) |
| 1130 | + runtimeContext.research_obj.packed_workflow(print_pack(uri)) |
1138 | 1131 |
|
1139 | 1132 | if args.print_pre:
|
1140 | 1133 | print(
|
|
0 commit comments