|
46 | 46 | "StepInputExpressionRequirement", |
47 | 47 | "ResourceRequirement", |
48 | 48 | "InitialWorkDirRequirement", |
49 | | - "LoadListingRequirement"] |
| 49 | + "http://commonwl.org/cwltool#LoadListingRequirement"] |
50 | 50 |
|
51 | 51 | cwl_files = ( |
52 | 52 | "Workflow.yml", |
@@ -430,15 +430,15 @@ def __init__(self, toolpath_object, **kwargs): |
430 | 430 | self.outputs_record_schema["fields"].append(c) |
431 | 431 |
|
432 | 432 | try: |
433 | | - self.inputs_record_schema = schema_salad.schema.make_valid_avro(self.inputs_record_schema, {}, set()) |
| 433 | + self.inputs_record_schema = cast(Dict[unicode, Any], schema_salad.schema.make_valid_avro(self.inputs_record_schema, {}, set())) |
434 | 434 | avro.schema.make_avsc_object(self.inputs_record_schema, self.names) |
435 | 435 | except avro.schema.SchemaParseException as e: |
436 | 436 | raise validate.ValidationException(u"Got error `%s` while processing inputs of %s:\n%s" % |
437 | 437 | (Text(e), self.tool["id"], |
438 | 438 | json.dumps(self.inputs_record_schema, indent=4))) |
439 | 439 |
|
440 | 440 | try: |
441 | | - self.outputs_record_schema = schema_salad.schema.make_valid_avro(self.outputs_record_schema, {}, set()) |
| 441 | + self.outputs_record_schema = cast(Dict[unicode, Any], schema_salad.schema.make_valid_avro(self.outputs_record_schema, {}, set())) |
442 | 442 | avro.schema.make_avsc_object(self.outputs_record_schema, self.names) |
443 | 443 | except avro.schema.SchemaParseException as e: |
444 | 444 | raise validate.ValidationException(u"Got error `%s` while processing outputs of %s:\n%s" % |
@@ -494,7 +494,7 @@ def _init_job(self, joborder, **kwargs): |
494 | 494 | builder.make_fs_access = kwargs.get("make_fs_access") or StdFsAccess |
495 | 495 | builder.fs_access = builder.make_fs_access(kwargs["basedir"]) |
496 | 496 |
|
497 | | - loadListingReq, _ = self.get_requirement("LoadListingRequirement") |
| 497 | + loadListingReq, _ = self.get_requirement("http://commonwl.org/cwltool#LoadListingRequirement") |
498 | 498 | if loadListingReq: |
499 | 499 | builder.loadListing = loadListingReq.get("loadListing") |
500 | 500 |
|
|
0 commit comments