OCP App SDK

OCP App SDK / SourceJob

Defined in: src/app/SourceJob.ts:48

Defined in: src/app/SourceJob.ts:68

Initializes a job to be run

SourceJobInvocation

details of the job invocation

Source

SourceJob

Defined in: src/app/SourceJob.ts:68

details of the job invocation

Defined in: src/app/SourceJob.ts:60

Set this to true during an interruptible operation, such as waiting for a long running export. When true, a job can be interrupted and resumed with the PREVIOUS Job state (the one perform was last called with). A job is normally expected to complete a job loop (perform) within < 60s. Your job CAN perform a loop for longer than 60 seconds if isInterruptible is set to true for a significant part of each 60 seconds of runtime and is performing NON-BLOCKING operations.

You MUST ensure the process is NOT BLOCKED while interruptible. This can be achieved by manually calling await this.sleep() regularly or is automatic if you are waiting on non-blocking calls.

SourceJob::sleep and SourceJob::performInterruptibleTask will set this value automatically.

Defined in: src/app/SourceJob.ts:68

Defined in: src/app/SourceJob.ts:88

Performs a unit of work. Jobs should perform a small unit of work and then return the current state. Perform is automatically called in a loop where the previously returned state will be given to the next iteration. Iteration will continue until complete is set to true in the returned job status.

SourceJobStatus

last known job state and status

Promise<SourceJobStatus>

The current JobStatus/state that can be used to perform the next iteration or resume a job if interrupted.

Defined in: src/app/SourceJob.ts:97

Wrapper for interruptible tasks, such as waiting for a long api call or a timeout loop waiting for a result. Interruptible tasks MUST BE NON-BLOCKING or must manually call await this.sleep() regularly (every few seconds).

T

() => Promise<T>

Promise<T>

const result = await this.performInterruptibleTask(() => fetch(...))); In this example, the job can be interrupted during the fetch operation, and if interrupted will be resumed with the previous job state.

Defined in: src/app/SourceJob.ts:79

Prepares to run a job. Prepare is called at the start of a job and again only if the job was interrupted and is being resumed. Use this function to read secrets and establish connections to simplify the job loop (perform).

ValueHash

a hash if params were supplied to the job run, otherwise an empty hash

SourceJobStatus

provided ONLY if the job was interrupted and should continue from the last known state

boolean

if the job was interrupted, resuming will be set to true when it is resumed

Promise<SourceJobStatus>

Defined in: src/app/SourceJob.ts:117

Sleep the job without CPU thrashing. Use this method to wait for long running tasks, like an export API.

number

duration to sleep in miliseconds

SourceSleepOptions

{interruptible: true} if the job can be interrupted while sleeping. A sleep that is not interruptible cannot safely be longer than about 55 seconds.

Promise<void>

await this.sleep(5000);