-
Notifications
You must be signed in to change notification settings - Fork 1.7k
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
Bugfix/177323594 Metadata in JPV2 #4121
Conversation
I see that you haven't updated any CHANGELOG files. Would it make sense to do so? |
@@ -187,7 +187,6 @@ func (r *runner) processUnfinishedRuns() { | |||
type ( | |||
memoryTaskRun struct { | |||
task Task | |||
taskRun TaskRun |
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.
realizing this isn't necessary since we have task
@@ -28,7 +28,7 @@ type ( | |||
Task interface { | |||
Type() TaskType | |||
DotID() string | |||
Run(ctx context.Context, taskRun TaskRun, inputs []Result) Result | |||
Run(ctx context.Context, meta JSONSerializable, inputs []Result) Result |
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.
the only thing used from the taskRun was the metadata, just making that explicit
72604c7
to
68e3146
Compare
@@ -312,48 +301,3 @@ func TestAdapterResponse_UnmarshalJSON_Happy(t *testing.T) { | |||
}) | |||
} | |||
} | |||
|
|||
func TestBridgeTask_AddsID(t *testing.T) { |
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.
Follow up ticket addresses the IDs
@@ -193,7 +193,7 @@ func (d Delegate) ServicesForSpec(jobSpec job.Job) (services []job.Service, err | |||
runResults := make(chan pipeline.RunWithResults, d.config.JobPipelineResultWriteQueueDepth()) | |||
oracle, err := ocr.NewOracle(ocr.OracleArgs{ | |||
Database: ocrdb, | |||
Datasource: dataSource{ | |||
Datasource: &dataSource{ |
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.
Curious, why change this to a pointer?
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.
@@ -173,7 +173,7 @@ func (o *orm) ProcessNextUnfinishedRun(ctx context.Context, fn ProcessRunFunc) ( | |||
// IDs. | |||
for i, trr := range trrs { | |||
for _, tr := range pRun.PipelineTaskRuns { | |||
if trr.TaskRun.DotID == tr.DotID { | |||
if trr.Task.DotID() == tr.DotID { |
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.
?
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.
to kill off TaskRun as it just contains redundant data with Task
…tkit/chainlink into bugfix/177323594-metadata-2
Follow up ticket https://www.pivotaltracker.com/story/show/177510496