-
Notifications
You must be signed in to change notification settings - Fork 0
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
SNOW-1932729: Add logging messages to snowpark-checkpoints-collectors #117
base: feature/SNOW-1928731/main
Are you sure you want to change the base?
SNOW-1932729: Add logging messages to snowpark-checkpoints-collectors #117
Conversation
e0d263a
to
73a553a
Compare
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.
I added a few suggestions.
...eckpoints-collectors/src/snowflake/snowpark_checkpoints_collector/summary_stats_collector.py
Outdated
Show resolved
Hide resolved
...rk-checkpoints-collectors/src/snowflake/snowpark_checkpoints_collector/utils/extra_config.py
Show resolved
Hide resolved
b663f00
to
4d8e4e4
Compare
...s/src/snowflake/snowpark_checkpoints_collector/column_collection/column_collector_manager.py
Show resolved
Hide resolved
...rk-checkpoints-collectors/src/snowflake/snowpark_checkpoints_collector/utils/extra_config.py
Show resolved
Hide resolved
|
||
if not is_checkpoint_enabled(normalized_checkpoint_name): | ||
LOGGER.info( | ||
"Checkpoint '%s' is disabled. Skipping collection.", checkpoint_name |
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.
"Checkpoint '%s' is disabled. Skipping collection.", checkpoint_name | |
"Checkpoint '%s' is disabled. Skipping collection.", normalized_checkpoint_name |
Should we used normalized_checkpoint_name instead checkpoint_name?
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.
Fixed in commit 421a9dd
) | ||
collection_point_result_manager.add_result(collection_point_result) | ||
collection_point_result.result = CollectionResult.PASS | ||
LOGGER.info("Checkpoint '%s' collected successfully", checkpoint_name) |
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.
LOGGER.info("Checkpoint '%s' collected successfully", checkpoint_name) | |
LOGGER.info("Checkpoint '%s' collected successfully", normalized_checkpoint_name) |
Also here
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.
Fixed in commit 421a9dd
|
||
except Exception as err: | ||
collection_point_result.result = CollectionResult.FAIL | ||
error_message = str(err) |
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.
Do we report failed checkpoints in another catch or do we have to add it?
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.
I think it is not necessary. The exception raised by this except
block will be caught by the log
decorator. Any exception caught by the log
decorator means that the collection failed.
raise Exception("No parquet files were generated.") | ||
LOGGER.info( | ||
"Wrote %s parquet files at '%s'", |
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.
"Wrote %s parquet files at '%s'", | |
"%s parquet files were written in '%s'", |
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.
Fixed in commit 421a9dd
7a72f49
to
421a9dd
Compare
421a9dd
to
37d3840
Compare
Motivation & Context
JIRA: SNOW-1932729
Description
This pull request introduces logging messages across multiple modules of the
snowpark-checkpoints-collectors
package. This messages aim to enhance the debugging and monitoring capabilities of the package.How Has This Been Tested?
Checklist
Review & Approval Requests
Note: Use GitHub's draft PR feature instead of tagging a PR as
DO NOT MERGE
.