Skip to content

Commit ff51fa5

Browse files
Apply suggestions from code review
Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
1 parent d99c2fa commit ff51fa5

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

airbyte_cdk/sources/declarative/schema/inferred_schema_loader.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,8 @@ def __post_init__(self, parameters: Mapping[str, Any]) -> None:
6565
self._parameters = parameters
6666
if not self.stream_name:
6767
self.stream_name = parameters.get("name", "")
68+
if not self.stream_name:
69+
raise ValueError("stream_name must be provided either directly or via the 'name' parameter")
6870

6971
def get_json_schema(self) -> Mapping[str, Any]:
7072
"""

0 commit comments

Comments
 (0)