The pipeline part and the assigner read the runner's events and pipeline by fingerprint, as CT14 names it

The join with CT14 (08812c7f) renames fp to fingerprint in the runner's Pipeline, PipelineStarted, PipelineEnded; the readers follow.

Builds: design 47 G §534, §550, §585, §646

Claude-Session: https://claude.ai/code/session_01JG73KEq4zoDfM9WtYpcQgZ

modules/mesh-delivery-assigner/cmd/mesh-delivery-assigner/pipelines.go

@@ -173,7 +173,7 @@ func (e *pipelineEnds) take(p mpr.PipelineEnded, passed bool) error {
 				return nil // an older end, or this one again
 			}
 		}
-		end := End{Source: p.Source, EndCount: p.EndCount, Fp: p.Fp, Commit: p.Commit, Passed: passed, Why: p.Why}
+		end := End{Source: p.Source, EndCount: p.EndCount, Fp: p.Fingerprint, Commit: p.Commit, Passed: passed, Why: p.Why}
 		value, err := json.Marshal(end)
 		if err != nil {
 			return err

modules/mesh-delivery-assigner/cmd/mesh-delivery-assigner/pipelines_test.go

@@ -56,7 +56,7 @@ func (m *memEnds) swap(key string, v []byte, rev uint64) error {
 }
 
 func pipe(module, branch string, source, count int64, fp, outcome string, steps ...mpr.StepResult) mpr.PipelineEnded {
-	return mpr.PipelineEnded{Module: module, Branch: branch, Source: source, EndCount: count, Fp: fp, Outcome: outcome, Steps: steps,
+	return mpr.PipelineEnded{Module: module, Branch: branch, Source: source, EndCount: count, Fingerprint: fp, Outcome: outcome, Steps: steps,
 		Pipeline: branch + "." + module, Commit: "c"}
 }
 

modules/mesh-delivery-pipeline/internal/pipeline/read.go

@@ -80,7 +80,7 @@ func (r Reads) Stands() (seat.StandsAnswer, error) {
 				continue
 			}
 			out = append(out, seat.Wait{Pipeline: p.Pipeline, Module: p.Module, Branch: p.Branch, Commit: p.Commit,
-				Group: p.Group, Run: p.Run, Source: p.Source, Revision: p.Revision, Fp: p.Fp, Step: s.Step,
+				Group: p.Group, Run: p.Run, Source: p.Source, Revision: p.Revision, Fingerprint: p.Fingerprint, Step: s.Step,
 				Artifact: s.Artifact, On: s.On, Since: *s.Started, V: 1})
 		}
 	}

modules/mesh-delivery-pipeline/internal/pipeline/start.go

@@ -64,7 +64,7 @@ func (s *Starter) Start(b Begin) (bool, error) {
 		now = s.Now().UTC()
 	}
 	key := Key(b.Branch, b.Source, b.Module)
-	p := seat.Pipeline{V: 1, Pipeline: key, Branch: b.Branch, Source: b.Source, Module: b.Module, Commit: b.Commit, Fp: b.Fp,
+	p := seat.Pipeline{V: 1, Pipeline: key, Branch: b.Branch, Source: b.Source, Module: b.Module, Commit: b.Commit, Fingerprint: b.Fp,
 		Group: b.Group, Repository: b.Repository, Revision: b.Revision, Outcome: seat.PipelineOutcomeRunning, Started: &now,
 		Steps: []seat.StepResult{}}
 	raw, err := json.Marshal(p)
@@ -78,7 +78,7 @@ func (s *Starter) Start(b Begin) (bool, error) {
 		return false, fmt.Errorf("the pipeline %s is not written: %w", key, err)
 	}
 	ev := seat.PipelineStarted{V: 1, At: &now, Pipeline: key, Branch: b.Branch, Source: b.Source, Module: b.Module,
-		Commit: b.Commit, Fp: b.Fp, Group: b.Group, Revision: b.Revision}
+		Commit: b.Commit, Fingerprint: b.Fp, Group: b.Group, Revision: b.Revision}
 	commitOrGroup := b.Commit
 	if b.Group != "" {
 		commitOrGroup = b.Group

modules/mesh-delivery-pipeline/internal/pipeline/start_test.go

@@ -50,7 +50,7 @@ func TestStarts(t *testing.T) {
 		t.Errorf("outdated asked %+v, want the package on its branch", asked)
 	}
 	var p seat.Pipeline
-	if err := json.Unmarshal(store["main.41.app"], &p); err != nil || p.Commit != "c1" || p.Fp != "src2:aa" || p.Revision != 9 ||
+	if err := json.Unmarshal(store["main.41.app"], &p); err != nil || p.Commit != "c1" || p.Fingerprint != "src2:aa" || p.Revision != 9 ||
 		p.Outcome != seat.PipelineOutcomeRunning || p.Source != 41 {
 		t.Errorf("the pipeline main.41.app = %+v (%v)", p, err)
 	}