Jobs.QueryLogs | Workflows

func (*JobClient) QueryLogs(
    ctx context.Context,
    jobID uuid.UUID,
    options ...job.TelemetryQueryOption,
) iter.Seq2[*workflows.LogRecord, error]

Query log records emitted while running a job.

The logs are lazily loaded and returned as a sequence of log records. Use Collect to transform the sequence into a slice.

Parameters

jobID uuid.UUID required

The ID of the job to query logs for.

options []job.TelemetryQueryOption

Options for querying logs.

Options

job.WithCursor(cursor *job.Cursor)

Start the query after the cursor returned by a previous page.

job.WithLimit(limit int64)

Limit the total number of log records yielded by the sequence.

job.WithSortDirection(direction job.SortDirection)

Sort logs by time. Use job.Ascending for oldest first or job.Descending for newest first.

Returns

A sequence of log records. Each record includes Time, SeverityText, Body, trace IDs, span IDs, and structured attributes.

Usage example

import (
    "fmt"
    "log/slog"
    "time"

    "github.com/google/uuid"
    "github.com/tilebox/tilebox-go/workflows/v1"
    "github.com/tilebox/tilebox-go/workflows/v1/job"
)

jobID := uuid.MustParse("019e07b1-916b-0630-f3ba-f1c33235d174")

for record, err := range client.Jobs.QueryLogs(
    ctx,
    jobID,
    job.WithSortDirection(job.Ascending),
) {
    if err != nil {
        slog.ErrorContext(
            ctx,
            "failed to query job logs",
            slog.Any("error", err),
        )
        return
    }

    fmt.Printf("%s %-5s %s\n",
        record.Time.Format(time.RFC3339),
        record.SeverityText,
        record.Body,
    )
}