Skip to content

Commit cc88b1c

Browse files
committed
de-duplicating the end of the new func
1 parent ccf92f4 commit cc88b1c

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

nodestream/project/project.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -345,11 +345,7 @@ def get_pipelines_schema(
345345
f"None of the specified pipelines {pipeline_names} were found. Available pipelines: {available_pipelines}"
346346
)
347347

348-
schema = filtered_project.make_schema()
349-
if type_overrides_file is not None:
350-
overrides_schema = Schema.read_from_file(type_overrides_file)
351-
schema.merge(overrides_schema)
352-
return schema
348+
return filtered_project.get_schema(type_overrides_file=type_overrides_file)
353349

354350
def get_child_expanders(self) -> Iterable[ExpandsSchema]:
355351
return self.scopes_by_name.values()

0 commit comments

Comments
 (0)