Skip to content
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

Changed how scattered tasks' status, duration and attempts are calculated #594

Merged
merged 4 commits into from
Mar 18, 2019

Conversation

rsasch
Copy link
Contributor

@rsasch rsasch commented Mar 15, 2019

Closes #590

@rsasch rsasch self-assigned this Mar 15, 2019
@rsasch rsasch requested review from aednichols and rexwangcc March 15, 2019 20:52
maxEnd = None
if maxEnd is not None and maxEnd < _parse_datetime(shard.get('end')):
maxEnd = _parse_datetime(shard.get('end'))
if minStart > _parse_datetime(shard.get('start')):
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Could you remind me why move this conditional logic a level deeper?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

it was moved under the if current_shard != shard.get('shardIndex'): check to only get the data from the latest attempts of each shard

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks for the explanation, that makes sense!

@rsasch rsasch merged commit 846ddb6 into master Mar 18, 2019
@rsasch rsasch deleted the rsasch/scattered-task-fix branch March 18, 2019 16:21
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants