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

delete immediate task on completion #95

Conversation

duoertai
Copy link
Collaborator

Why make this pull request?

[Explain why you are making this pull request and what problem it solves.]

What has changed

[Summarize what components of the repo is updated]

[Link to xdb-apis/xdb-golang-sdk PRs if it's on top of any API changes]

  • API change link: ...
  • Golang SDK change link: ...
  • Server Component 1: ...
  • Server Component 2: ...

How to test this pull request?

[If writing Integration test in Golang SDK repo, please provide link to the pull request of Golang SDK Repo]

[It's recommended to write integration test in Golang SDK repo, and enabled in this server repo first,
without enabling in the SDK repo. After this PR is merged, enable and merge the integration test in the SDK repo]

[Alternatively if Java/other SDK repo is preferred, then just test locally against server PR.
After the server PR is merged, merge the integration test in the SDK repo]

Checklist before merge

[ ] If applicable, merge the xdb-apis/xdb-golang-sdk PRs to main branch
[ ] If applicable, merge the xdb-apis/xdb-apis PRs to main branch
[ ] Update go.mod to use the commitID of the main branches for xdb-apis/xdb-golang-sdk

@duoertai
Copy link
Collaborator Author

tested locally by querying xdb_sys_immediate_tasks

Copy link

codecov bot commented Nov 13, 2023

Codecov Report

Attention: 7 lines in your changes are missing coverage. Please review.

Comparison is base (689585f) 65.51% compared to head (6cf3f0e) 65.62%.

Files Patch % Lines
persistence/sql/complete_execute.go 57.14% 2 Missing and 1 partial ⚠️
persistence/sql/wait_until.go 57.14% 2 Missing and 1 partial ⚠️
engine/immediate_task_queue.go 0.00% 1 Missing ⚠️
Additional details and impacted files
@@            Coverage Diff             @@
##             main      #95      +/-   ##
==========================================
+ Coverage   65.51%   65.62%   +0.10%     
==========================================
  Files          77       77              
  Lines        5849     5829      -20     
==========================================
- Hits         3832     3825       -7     
+ Misses       1775     1761      -14     
- Partials      242      243       +1     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

@longquanzheng
Copy link
Contributor

we also need to remove the logic of batch delete in immediate_task_queue

@@ -98,7 +97,6 @@ func (w *immediateTaskQueueImpl) Start() error {
case <-w.pollTimer.FireChan():
w.pollAndDispatchAndPrepareNext()
case <-w.commitTimer.FireChan():
Copy link
Contributor

Choose a reason for hiding this comment

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

I don't think we need the commit timer anymore?

@duoertai duoertai merged commit 88b6995 into main Nov 16, 2023
4 of 5 checks passed
@duoertai duoertai deleted the 58-consider-delete-worker-task-on-completion-instead-of-batch-deletion branch November 16, 2023 21:14
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

consider delete worker task on completion instead of batch deletion
2 participants