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

fix(artifact): fix retry file process #97

Merged
merged 4 commits into from
Sep 19, 2024

Conversation

Yougigun
Copy link
Collaborator

@Yougigun Yougigun commented Sep 19, 2024

Because

  1. when all processing workers are busy, the dispatch worker continues to send tasks to the queue. These tasks are not held by any workers, so the dispatcher may keep sending the same tasks to the queue.

  2. when chunk text is empty, it still insert into db.

This commit

  1. Add a check at the beginning of each process step to verify the file’s processing state in the database. If the state does not matches the current process state, discard the file process task.

  2. Set buffer of worker queue to zero to prevent out of date file status being queued

  3. Skip the chunk's text if it text is empty

Copy link

linear bot commented Sep 19, 2024

@Yougigun Yougigun merged commit 97ff707 into main Sep 19, 2024
15 checks passed
@Yougigun Yougigun deleted the gary/ins-6315-fix-file-process-retry branch September 19, 2024 15:50
Yougigun pushed a commit that referenced this pull request Sep 24, 2024
🤖 I have created a release *beep* *boop*
---


##
[0.15.0-alpha](v0.14.0-alpha...v0.15.0-alpha)
(2024-09-24)


### Features

* **artifact:** add response from pipeline when calling fails
([#100](#100))
([0eef0cc](0eef0cc))
* **artifact:** support csv file type upload and some improvements
([#101](#101))
([ac2eb86](ac2eb86))
* **artifact:** support xls
([#99](#99))
([ae30e81](ae30e81))
* **catalog:** add catalog uid in list catalog api
([289fcfa](289fcfa))


### Bug Fixes

* **artifact:** fix retry file process
([#97](#97))
([97ff707](97ff707))


### Miscellaneous Chores

* release 1.15.0
([4ac1378](4ac1378))
* release 1.15.0-alpha
([4770a4a](4770a4a))
* release v0.15.0-alpha
([636702d](636702d))

---
This PR was generated with [Release
Please](https://github.com/googleapis/release-please). See
[documentation](https://github.com/googleapis/release-please#release-please).
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
No open projects
Status: 👋 Done
Development

Successfully merging this pull request may close these issues.

2 participants