-
Notifications
You must be signed in to change notification settings - Fork 1.6k
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
task callsites: part 2 #4188
task callsites: part 2 #4188
Conversation
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.
Looks good! Only a few minor things.
core/dbt/task/freshness.py
Outdated
if hasattr(result, 'node'): | ||
source_name = result.node.source_name | ||
table_name = result.node.name | ||
else: | ||
source_name = result.source_name | ||
table_name = result.table_name | ||
if result.status == FreshnessStatus.RuntimeErr: | ||
fire_event(PrintHookEndErrorLine(source_name=source_name, | ||
table_name=table_name, | ||
index=self.node_index, | ||
total=self.num_nodes, | ||
execution_time=result.execution_time)) | ||
elif result.status == FreshnessStatus.Error: | ||
fire_event(PrintHookEndErrorStaleLine(source_name=source_name, | ||
table_name=table_name, | ||
index=self.node_index, | ||
total=self.num_nodes, | ||
execution_time=result.execution_time)) | ||
elif result.status == FreshnessStatus.Warn: | ||
fire_event(PrintHookEndWarnLine(source_name=source_name, | ||
table_name=table_name, | ||
index=self.node_index, | ||
total=self.num_nodes, | ||
execution_time=result.execution_time)) | ||
else: | ||
fire_event(PrintHookEndPassLine(source_name=source_name, | ||
table_name=table_name, | ||
index=self.node_index, | ||
total=self.num_nodes, | ||
execution_time=result.execution_time)) |
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 looks like it was pretty non-trivial to change. I really like what you did with it here: It brings the important stuff to the top, and buries the stuff we don't care about as much. Nice job.
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.
Perfect. Thanks!
* add struct logging to docs serve * remove merge fluff * struct logging to seed command * converting print to use structured logging * more structured logging print conversion * pulling apart formatting more * added struct logging by disecting printer.py * add struct logging to runnable * add struct logging to task init * fixed formatting * more formatting and moving things around
* add struct logging to docs serve * remove merge fluff * struct logging to seed command * converting print to use structured logging * more structured logging print conversion * pulling apart formatting more * added struct logging by disecting printer.py * add struct logging to runnable * add struct logging to task init * fixed formatting * more formatting and moving things around
* add struct logging to docs serve * remove merge fluff * struct logging to seed command * converting print to use structured logging * more structured logging print conversion * pulling apart formatting more * added struct logging by disecting printer.py * add struct logging to runnable * add struct logging to task init * fixed formatting * more formatting and moving things around
* add struct logging to docs serve * remove merge fluff * struct logging to seed command * converting print to use structured logging * more structured logging print conversion * pulling apart formatting more * added struct logging by disecting printer.py * add struct logging to runnable * add struct logging to task init * fixed formatting * more formatting and moving things around
* add struct logging to docs serve * remove merge fluff * struct logging to seed command * converting print to use structured logging * more structured logging print conversion * pulling apart formatting more * added struct logging by disecting printer.py * add struct logging to runnable * add struct logging to task init * fixed formatting * more formatting and moving things around automatic commit by git-black, original commits: 3cafc9e
* add struct logging to docs serve * remove merge fluff * struct logging to seed command * converting print to use structured logging * more structured logging print conversion * pulling apart formatting more * added struct logging by disecting printer.py * add struct logging to runnable * add struct logging to task init * fixed formatting * more formatting and moving things around automatic commit by git-black, original commits: 3cafc9e 73f7fba
* add struct logging to docs serve * remove merge fluff * struct logging to seed command * converting print to use structured logging * more structured logging print conversion * pulling apart formatting more * added struct logging by disecting printer.py * add struct logging to runnable * add struct logging to task init * fixed formatting * more formatting and moving things around automatic commit by git-black, original commits: 3cafc9e 9cc7a7a
Description
Modifying call sites for structured logging in core/dbt/task
#4183 is Part 1 of the same dir
Checklist
CHANGELOG.md
and added information about my change