-
Notifications
You must be signed in to change notification settings - Fork 378
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
check data version when accept from executor done chan #3402
check data version when accept from executor done chan #3402
Conversation
Codecov Report
@@ Coverage Diff @@
## master #3402 +/- ##
=======================================
Coverage 18.14% 18.14%
=======================================
Files 1411 1411
Lines 144748 144764 +16
=======================================
+ Hits 26263 26273 +10
- Misses 115857 115862 +5
- Partials 2628 2629 +1
|
16f30ef
to
78b332e
Compare
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.
Adjust all related var names.
Version string | ||
} | ||
|
||
func (pt *PipelineTask) GenerateExecutorVersion() string { |
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.
What is executor version? No, executor doesn't have version.
You should use GenerateExecutorDoneChanDataVersion
.
return fmt.Sprintf("%s-%d-loop-%d", CtxExecutorChVersionPrefix, pt.ID, pt.Extra.LoopOptions.LoopedTimes) | ||
} | ||
|
||
func (pt *PipelineTask) CheckExecutorVersion(actualVersion string) error { |
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.
Same.
78b332e
to
19d4d07
Compare
@@ -67,11 +67,12 @@ func (d *define) Create(ctx context.Context, task *spec.PipelineTask) (interface | |||
func (d *define) Start(ctx context.Context, task *spec.PipelineTask) (interface{}, error) { | |||
|
|||
go func(ctx context.Context, task *spec.PipelineTask) { | |||
executorVersion := task.GenerateExecutorDoneChanDataVersion() |
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.
xxx
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.
doneChanDataVersion
@@ -278,6 +279,26 @@ func (pt *PipelineTask) GetMetadata() apistructs.Metadata { | |||
return pt.Result.Metadata | |||
} | |||
|
|||
type ExecutorChanData struct { |
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.
ExecutorDoneChanData
19d4d07
to
94f2bbf
Compare
/approve |
/cherry-pick release/1.5 |
What type of this PR
Add one of the following kinds:
/kind bugfix
What this PR does / why we need it:
check data version when accept from executor done chan
Which issue(s) this PR fixes:
Specified Reviewers:
/assign @your-reviewer
ChangeLog
Need cherry-pick to release versions?
Add comment like
/cherry-pick release/1.0
when this PR is merged.