We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a79caa6 commit 4a0bf13Copy full SHA for 4a0bf13
go/bindings/task_service.go
@@ -53,6 +53,13 @@ func NewTaskService(
53
return nil, fmt.Errorf("creating logging pipe: %w", err)
54
}
55
config.LogFileFd = int32(wDescriptor)
56
+ // Log so that we can know the association between tasks and log file descriptors,
57
+ // for troubleshooting issues with missing logs.
58
+ logrus.WithFields(logrus.Fields{
59
+ "task_name": config.TaskName,
60
+ "logs_write_fd": wDescriptor,
61
+ "log_read_fd": logReader.Fd(),
62
+ }).Info("created new pipe for task logs")
63
64
// Rust services produce canonical JSON encodings of ops::Log into `wDescriptor`.
65
// Parse each and pass to our `publisher`.
0 commit comments