Skip to main content
func (*JobClient) Query(
    ctx context.Context,
    options ...job.QueryOption,
) iter.Seq2[*workflows.Job, error]
Query jobs in the specified interval. The jobs are lazily loaded and returned as a sequence of Jobs. The jobs are returned sorted by creation time in reverse order. The output sequence can be transformed into a slice of Job using Collect function.

Parameters

options
[]job.QueryOption
Options for querying jobs

Options

WithTemporalExtent(temporalExtent query.TemporalExtent)
required
Specify the time interval for which data should be queried. Right now, a temporal extent is required for every query.
WithAutomationID(automationID uuid.UUID)
Specify the automation id for which data should be queried. Only jobs that were created by the specified automation will be returned.

Returns

A sequence of jobs.
import (
  "time"
  workflows "github.com/tilebox/tilebox-go/workflows/v1"
  "github.com/tilebox/tilebox-go/workflows/v1/job"
	"github.com/tilebox/tilebox-go/query"
)

interval := query.NewTimeInterval(
  time.Now().Add(-24 * time.Hour),
  time.Now(),
)

jobs, err := workflows.Collect(
  client.Jobs.Query(ctx, 
    job.WithTemporalExtent(interval),
  ),
)