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

Split lease task queue API into 2 #2269

Merged
merged 10 commits into from Dec 11, 2021
Merged

Conversation

wxing1292
Copy link
Contributor

What changed?

  • Split matching persistence LeaseTaskQueue API into
    • CreateTaskQueue
    • GetTaskQueue
  • Add new task queue UT
  • Add new task queue task UT
  • Deprecate legacy matching task tests
  • Modify logic accordingly

Why?
Code cleanup & test cleanup

How did you test it?
New tests

Potential risks
N/A

Is hotfix candidate?
No

@wxing1292
Copy link
Contributor Author

review #2262 first

@wxing1292 wxing1292 force-pushed the what-why-how branch 3 times, most recently from 1ecafb3 to 4f5d063 Compare December 7, 2021 09:47
* Split matching persistence LeaseTaskQueue API into
  * CreateTaskQueue
  * GetTaskQueue
* Add new task queue UT
* Add new task queue task UT
* Deprecate legacy matching task tests
@wxing1292 wxing1292 changed the title Split least task queue API into 2 Split lease task queue API into 2 Dec 10, 2021
Copy link
Member

@yiminc yiminc left a comment

Choose a reason for hiding this comment

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

This PR include changes from 2263, should I hold on reviewing this until 2263 is landed?

@@ -67,6 +67,10 @@ import (
"go.temporal.io/server/service/history/tasks"
)

// TimePrecision is needed to account for database timestamp precision.
// Cassandra only provides milliseconds timestamp precision, so we need to use tolerance when doing comparison
const TimePrecision = 2 * time.Millisecond
Copy link
Member

Choose a reason for hiding this comment

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

this is not used anywhere in this PR?

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 is used by existing persistence tests, simply moving the definition from file to be deleted to here

@wxing1292 wxing1292 marked this pull request as ready for review December 11, 2021 00:16
@wxing1292 wxing1292 requested a review from a team December 11, 2021 00:16
service/matching/db.go Outdated Show resolved Hide resolved
service/matching/db.go Outdated Show resolved Hide resolved
taskQueue := &taskqueuepb.TaskQueue{Name: tl}
taskQueue := &taskqueuepb.TaskQueue{
Name: tl,
Kind: enumspb.TASK_QUEUE_KIND_NORMAL,
Copy link
Member

Choose a reason for hiding this comment

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

the Unspecified should be treated as Normal.

@wxing1292 wxing1292 enabled auto-merge (squash) December 11, 2021 05:14
@wxing1292 wxing1292 merged commit 20bf977 into temporalio:master Dec 11, 2021
@wxing1292 wxing1292 deleted the what-why-how branch December 11, 2021 05:39
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.

None yet

2 participants