-
Notifications
You must be signed in to change notification settings - Fork 47
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
Added logic to clean up executor interchange log #513
Conversation
…ogs when there is no outstanding task
Codecov Report
@@ Coverage Diff @@
## main #513 +/- ##
==========================================
- Coverage 38.52% 36.14% -2.39%
==========================================
Files 27 27
Lines 2855 3511 +656
==========================================
+ Hits 1100 1269 +169
- Misses 1755 2242 +487
Continue to review full report at Codecov.
|
@@ -47,7 +47,13 @@ def strategize(self, *args, **kwargs): | |||
|
|||
def _strategize(self, *args, **kwargs): | |||
task_breakdown = self.interchange.get_outstanding_breakdown() | |||
logger.info(f"Task breakdown {task_breakdown}") | |||
num_tasks = 0 |
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.
no need to sum here. We can log if there is any non-zero entry, which is a bit faster.
Although I don't know what that "breakdown" object is, this seems to me like an unnecessary change which potentially loses information. @yadudoc, I'd like to close (not merge) this to cleanup our outstanding PRs. Do you agree? |
@sirosen I agree. Sorry, I did not see your comment here sooner. |
As described in Issue #511, for endpoint, there is a log line being generated every second for executor interchange, even there is no outstanding task. It is good for debugging, but might not be the case for production running. This PR changes the log level from
info
todebug
, when there is no outstanding task.