Skip to main content
Module

x/windmill/windmill-api/types/ObservableAPI.ts>ObservableJobApi

Windmill deno client (separated from the main repo because most of the code is auto-generated from the openapi and not worth committing)
Go to Latest
class ObservableJobApi
import { ObservableJobApi } from "https://deno.land/x/windmill@v1.28.1/windmill-api/types/ObservableAPI.ts";

Constructors

new
ObservableJobApi(
configuration: Configuration,
requestFactory?: JobApiRequestFactory,
responseProcessor?: JobApiResponseProcessor,
)

Properties

private
configuration: Configuration
private
requestFactory: JobApiRequestFactory
private
responseProcessor: JobApiResponseProcessor

Methods

cancelQueuedJob(
workspace: string,
id: string,
inlineObject16: InlineObject16,
_options?: Configuration,
): Observable<string>

cancel queued job

deleteCompletedJob(
workspace: string,
id: string,
_options?: Configuration,
): Observable<CompletedJob>

delete completed job (erase content but keep run id)

getCompletedJob(
workspace: string,
id: string,
_options?: Configuration,
): Observable<CompletedJob>

get completed job

getJob(
workspace: string,
id: string,
_options?: Configuration,
): Observable<Job>

get job

getJobUpdates(
workspace: string,
id: string,
running?: boolean,
logOffset?: number,
_options?: Configuration,
): Observable<InlineResponse2006>

get job updates

listCompletedJobs(
workspace: string,
orderDesc?: boolean,
createdBy?: string,
parentJob?: string,
scriptPathExact?: string,
scriptPathStart?: string,
scriptHash?: string,
createdBefore?: Date,
createdAfter?: Date,
success?: boolean,
jobKinds?: string,
isSkipped?: boolean,
_options?: Configuration,
): Observable<Array<CompletedJob>>

list all available completed jobs

listJobs(
workspace: string,
createdBy?: string,
parentJob?: string,
scriptPathExact?: string,
scriptPathStart?: string,
scriptHash?: string,
createdBefore?: Date,
createdAfter?: Date,
jobKinds?: string,
isSkipped?: boolean,
success?: boolean,
_options?: Configuration,
): Observable<Array<Job>>

list all available jobs

listQueue(
workspace: string,
orderDesc?: boolean,
createdBy?: string,
parentJob?: string,
scriptPathExact?: string,
scriptPathStart?: string,
scriptHash?: string,
createdBefore?: Date,
createdAfter?: Date,
success?: boolean,
jobKinds?: string,
_options?: Configuration,
): Observable<Array<QueuedJob>>

list all available queued jobs

runFlowByPath(
workspace: string,
path: string,
requestBody: { [key: string]: any; },
scheduledFor?: Date,
scheduledInSecs?: number,
parentJob?: string,
_options?: Configuration,
): Observable<string>

run flow by path

runFlowPreview(
workspace: string,
flowPreview: FlowPreview,
_options?: Configuration,
): Observable<string>

run flow preview

runScriptByHash(
workspace: string,
hash: string,
body: any,
scheduledFor?: Date,
scheduledInSecs?: number,
parentJob?: string,
_options?: Configuration,
): Observable<string>

run script by hash

runScriptByPath(
workspace: string,
path: string,
requestBody: { [key: string]: any; },
scheduledFor?: Date,
scheduledInSecs?: number,
parentJob?: string,
_options?: Configuration,
): Observable<string>

run script by path

runScriptPreview(
workspace: string,
preview: Preview,
_options?: Configuration,
): Observable<string>

run script preview

runWaitResultScriptByPath(
workspace: string,
path: string,
requestBody: { [key: string]: any; },
scheduledFor?: Date,
scheduledInSecs?: number,
parentJob?: string,
_options?: Configuration,
): Observable<any>

run script by path