Skip to content

Commit ee03095

Browse files
authored
Add timestamps to k8s logs (#516)
1 parent bc6b889 commit ee03095

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

task/k8s/resources/resource_job.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -332,7 +332,9 @@ func (j *Job) Logs(ctx context.Context) ([]string, error) {
332332
var result []string
333333

334334
for _, pod := range pods.Items {
335-
logs, err := j.Client.Services.Core.Pods(j.Client.Namespace).GetLogs(pod.Name, &kubernetes_core.PodLogOptions{}).Stream(ctx)
335+
logs, err := j.Client.Services.Core.Pods(j.Client.Namespace).GetLogs(pod.Name, &kubernetes_core.PodLogOptions{
336+
Timestamps: true,
337+
}).Stream(ctx)
336338
if err != nil {
337339
if statusErr, ok := err.(*kubernetes_errors.StatusError); ok && strings.HasSuffix(statusErr.ErrStatus.Message, "ContainerCreating") {
338340
continue

0 commit comments

Comments
 (0)