|
17 | 17 |
|
18 | 18 | import shellescape
|
19 | 19 | from schema_salad import validate
|
| 20 | +from schema_salad.avro.schema import Schema |
20 | 21 | from schema_salad.ref_resolver import file_uri, uri_file_path
|
21 | 22 | from schema_salad.sourceline import SourceLine
|
22 | 23 | from six import string_types
|
@@ -612,17 +613,17 @@ def makeWorkflowException(msg):
|
612 | 613 |
|
613 | 614 | if compute_checksum:
|
614 | 615 | adjustFileObjs(ret, partial(compute_checksums, fs_access))
|
615 |
| - |
616 |
| - validate.validate_ex( |
617 |
| - self.names.get_name("outputs_record_schema", ""), ret, |
| 616 | + expected_schema = cast(Schema, self.names.get_name( |
| 617 | + "outputs_record_schema", "")) |
| 618 | + validate.validate_ex(expected_schema, ret, |
618 | 619 | strict=False, logger=_logger_validation_warnings)
|
619 | 620 | if ret is not None and builder.mutation_manager is not None:
|
620 | 621 | adjustFileObjs(ret, builder.mutation_manager.set_generation)
|
621 | 622 | return ret if ret is not None else {}
|
622 | 623 | except validate.ValidationException as e:
|
623 | 624 | raise WorkflowException(
|
624 |
| - "Error validating output record. " + Text(e) + "\n in " + |
625 |
| - json_dumps(ret, indent=4)) |
| 625 | + "Error validating output record. " + Text(e) + "\n in " |
| 626 | + + json_dumps(ret, indent=4)) |
626 | 627 | finally:
|
627 | 628 | if builder.mutation_manager and readers:
|
628 | 629 | for r in readers.values():
|
|
0 commit comments