Skip to content

SDK API Reference / JobSDK

Class: JobSDK

Job API - manage and execute jobs

Methods

getUserInfo()

getUserInfo(): Promise<UserInfo>

Get current user information

Returns

Promise<UserInfo>

User information including email


kill()

kill(jobId): Promise<void>

Kill a job

Parameters

jobId

string

Job ID to kill

Returns

Promise<void>


list()

list(options?): Promise<Job[]>

List jobs

Parameters

options?

Optional pagination and filter options

from?

number

Starting offset (inclusive, default: 0)

status?

string

Filter by job status (queued, running, success, error)

to?

number

Ending offset (inclusive)

Returns

Promise<Job[]>

Array of jobs with normalized timestamps


result()

result<T>(jobId): Promise<T[]>

Get job results

Type Parameters

T

T = unknown

Parameters

jobId

string

Job ID

Returns

Promise<T[]>

Array of result rows


show()

show(jobId): Promise<Job>

Show job details

Parameters

jobId

string

Job ID

Returns

Promise<Job>

Job details with normalized timestamps


submit()

submit(database, query, jobType): Promise<{ job_id: string; }>

Submit a job

Parameters

database

string

Database name

query

string

SQL query to execute

jobType

Job type (trino or hive)

"trino" | "hive"

Returns

Promise<{ job_id: string; }>

Job submission response with job_id