-
Notifications
You must be signed in to change notification settings - Fork 4.1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
SAT: Improve message about errors in stream's schema #6934
Conversation
@@ -201,7 +201,7 @@ def _validate_schema(records: List[AirbyteRecordMessage], configured_catalog: Co | |||
for stream_name, errors in streams_errors.items(): | |||
errors = map(str, errors.values()) | |||
str_errors = f"\n{bar}\n".join(errors) | |||
logging.error(f"The {stream_name} stream has the following schema errors:\n{str_errors}") | |||
logging.error(f"\nThe {stream_name} stream has the following schema errors:\n{str_errors}") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this is a strange way to do this, is it possible to place the newline on the previous log line instead of the new log line?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
got it. thanks for the explanation.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
one non-blocking comment.
/publish connector=bases/source-acceptance-test
|
What
Closes #6933.
Now it looks like this: