Skip to content

Commit 0dc80db

Browse files
committed
More logging to understand how it works
1 parent 1eaed41 commit 0dc80db

File tree

2 files changed

+10
-10
lines changed

2 files changed

+10
-10
lines changed

cli/internal/run/run.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1038,7 +1038,8 @@ func (g *completeGraph) getPackageTaskVisitor(ctx gocontext.Context, visitor fun
10381038
fmt.Printf("\t taskID: %#v\n", taskID)
10391039
fmt.Printf("\t task: %#v\n", task)
10401040
fmt.Printf("\t Pipeline:\n\t\t%#v\n", g.Pipeline)
1041-
fmt.Printf("\t taskDefintion (looked up with taskID):\n\t\t%#v\n", taskDefinition)
1041+
fmt.Printf("----------------------------\n")
1042+
fmt.Printf("\t taskDefintion (looked up with taskID \"%#v\"):\n\t\t%#v\n", taskID, taskDefinition)
10421043
if !ok {
10431044
// then check for regular tasks
10441045
fallbackTaskDefinition, notcool := g.Pipeline[task]
@@ -1047,7 +1048,7 @@ func (g *completeGraph) getPackageTaskVisitor(ctx gocontext.Context, visitor fun
10471048
return nil
10481049
}
10491050
// override if we need to...
1050-
fmt.Printf("\t fallbackTaskDefinition (looked up with task) %#v\n", fallbackTaskDefinition)
1051+
fmt.Printf("\t fallbackTaskDefinition (looked up with task \"%#v\") %#v\n", task, fallbackTaskDefinition)
10511052
taskDefinition = fallbackTaskDefinition
10521053
}
10531054
return visitor(ctx, &nodes.PackageTask{

cli/internal/taskhash/taskhash.go

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -159,6 +159,7 @@ type packageFileHashes map[packageFileHashKey]string
159159
// in the task graph. Must be called before calculating task hashes.
160160
func (th *Tracker) CalculateFileHashes(allTasks []dag.Vertex, workerCount int, repoRoot turbopath.AbsolutePath) error {
161161
fmt.Printf("CalculateFileHashes()\n")
162+
162163
hashTasks := make(util.Set)
163164

164165
for i, v := range allTasks {
@@ -172,7 +173,6 @@ func (th *Tracker) CalculateFileHashes(allTasks []dag.Vertex, workerCount int, r
172173
}
173174
pkgName, _ := util.GetPackageTaskFromId(taskID)
174175
if pkgName == th.rootNode {
175-
fmt.Printf("\tContinue\n")
176176
continue
177177
}
178178

@@ -181,19 +181,18 @@ func (th *Tracker) CalculateFileHashes(allTasks []dag.Vertex, workerCount int, r
181181
return fmt.Errorf("missing pipeline entry %v", taskID)
182182
}
183183

184-
taskDefinition.Inputs = append(taskDefinition.Inputs, "./package.json")
184+
// taskDefinition.Inputs = append(taskDefinition.Inputs, "./package.json")
185185

186186
pfs := &packageFileSpec{
187187
pkg: pkgName,
188188
inputs: taskDefinition.Inputs,
189189
}
190190

191-
fmt.Printf("\ttaskDefinition.Inputs: %v\n", taskDefinition.Inputs)
192-
fmt.Printf("\tpfs.inputs: %v\n", pfs.inputs)
193-
194191
hashTasks.Add(pfs)
195192
}
196193

194+
fmt.Printf("\thashTasks\n\t\t %#v\n", hashTasks)
195+
197196
hashes := make(map[packageFileHashKey]string)
198197
hashQueue := make(chan *packageFileSpec, workerCount)
199198
hashErrs := &errgroup.Group{}
@@ -211,14 +210,14 @@ func (th *Tracker) CalculateFileHashes(allTasks []dag.Vertex, workerCount int, r
211210
}
212211
th.mu.Lock()
213212
pfsKey := packageFileSpec.ToKey()
214-
fmt.Printf("\tadding to hashes\n")
215-
fmt.Printf("\t\t\"%v\": %v\n", pfsKey, hash)
213+
fmt.Printf("\tadding key \"%#v\" with value \"%#v\"\n", pfsKey, hash)
216214
hashes[pfsKey] = hash
217215
th.mu.Unlock()
218216
}
219217
return nil
220218
})
221219
}
220+
222221
for ht := range hashTasks {
223222
hashQueue <- ht.(*packageFileSpec)
224223
}
@@ -229,7 +228,7 @@ func (th *Tracker) CalculateFileHashes(allTasks []dag.Vertex, workerCount int, r
229228
}
230229
th.packageInputsHashes = hashes
231230

232-
fmt.Printf("\tth.packageInputsHashes: %v\n", th.packageInputsHashes)
231+
fmt.Printf("\t tracker:\n\t\t%#v\n", th)
233232
return nil
234233
}
235234

0 commit comments

Comments
 (0)