Jobs.Query

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),
    job.WithJobStates(job.Running, job.Started),
  ),
)

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),
    job.WithJobStates(job.Running, job.Started),
  ),
)

func (*JobClient) Query(
    ctx context.Context,
    options ...job.QueryOption,
) iter.Seq2[*workflows.Job, error]

Query jobs matching the provided options. The jobs are lazily loaded across pages and returned as a sequence of jobs. The output sequence can be transformed into a slice of Job using Collect function.

Parameters

[]job.QueryOption

Options for querying jobs

Options

Filter jobs by time or job ID interval.

Filter jobs by the automations that submitted them.

Filter jobs by job state.

Filter jobs by name.

Filter jobs by the states of their tasks. Only jobs that have at least one task in any of the given states will be returned. Useful for finding jobs with optional task failures.

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

Limit the total number of jobs yielded by the sequence.

Sort jobs by submission date. Use job.Ascending for oldest first or job.Descending for newest first.

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),
    job.WithJobStates(job.Running, job.Started),
  ),
)

Python

Go

Parameters

Options

Returns

​Parameters

​Options

​Returns

Parameters

Options

Returns