Unverified Commit 0f89d345 authored by Hannah Howard's avatar Hannah Howard Committed by GitHub

Add debug logging (#121)

Co-authored-by: default avatarraulk <raul@protocol.ai>
parent fcb8c292
......@@ -72,6 +72,7 @@ func (qe *queryExecutor) processQueriesWorker() {
log.Info("Empty task on peer request stack")
continue
}
log.Debugw("beginning response execution", "id", key.requestID, "peer", key.p.String(), "root_cid", taskData.request.Root().String())
status, err := qe.executeTask(key, taskData)
isCancelled := err != nil && isContextErr(err)
if isCancelled {
......@@ -81,6 +82,7 @@ func (qe *queryExecutor) processQueriesWorker() {
case qe.messages <- &finishTaskRequest{key, status, err}:
case <-qe.ctx.Done():
}
log.Debugw("finishing response execution", "id", key.requestID, "peer", key.p.String(), "root_cid", taskData.request.Root().String())
}
qe.queryQueue.TasksDone(pid, tasks...)
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment