feat: Lakeflow Jobs Plugin

docs/docs/api/appkit/Interface.BasePluginConfig.md

@@ -2,6 +2,10 @@
 
 Base configuration interface for AppKit plugins
 
+## Extended by
+
+- [`IJobsConfig`](Interface.IJobsConfig.md)
+
 ## Indexable
 
 ```ts

docs/docs/api/appkit/Interface.IJobsConfig.md

@@ -0,0 +1,79 @@
+# Interface: IJobsConfig
+
+Configuration for the Jobs plugin.
+
+## Extends
+
+- [`BasePluginConfig`](Interface.BasePluginConfig.md)
+
+## Indexable
+
+```ts
+[key: string]: unknown
+```
+
+## Properties
+
+### host?
+
+```ts
+optional host: string;
+```
+
+#### Inherited from
+
+[`BasePluginConfig`](Interface.BasePluginConfig.md).[`host`](Interface.BasePluginConfig.md#host)
+
+***
+
+### jobs?
+
+```ts
+optional jobs: Record<string, JobConfig>;
+```
+
+Named jobs to expose. Each key becomes a job accessor.
+
+***
+
+### name?
+
+```ts
+optional name: string;
+```
+
+#### Inherited from
+
+[`BasePluginConfig`](Interface.BasePluginConfig.md).[`name`](Interface.BasePluginConfig.md#name)
+
+***
+
+### pollIntervalMs?
+
+```ts
+optional pollIntervalMs: number;
+```
+
+Poll interval for waitForRun in milliseconds. Defaults to 5000.
+
+***
+
+### telemetry?
+
+```ts
+optional telemetry: TelemetryOptions;
+```
+
+#### Inherited from
+
+[`BasePluginConfig`](Interface.BasePluginConfig.md).[`telemetry`](Interface.BasePluginConfig.md#telemetry)
+
+***
+
+### timeout?
+
+```ts
+optional timeout: number;
+```
+
+Operation timeout in milliseconds. Defaults to 60000.

docs/docs/api/appkit/Interface.JobAPI.md

@@ -0,0 +1,155 @@
+# Interface: JobAPI
+
+User-facing API for a single configured job.
+
+## Methods
+
+### cancelRun()
+
+```ts
+cancelRun(runId: number): Promise<ExecutionResult<void>>;
+```
+
+Cancel a specific run.
+
+#### Parameters
+
+| Parameter | Type |
+| ------ | ------ |
+| `runId` | `number` |
+
+#### Returns
+
+`Promise`\<[`ExecutionResult`](TypeAlias.ExecutionResult.md)\<`void`\>\>
+
+***
+
+### getJob()
+
+```ts
+getJob(): Promise<ExecutionResult<Job>>;
+```
+
+Get the job definition.
+
+#### Returns
+
+`Promise`\<[`ExecutionResult`](TypeAlias.ExecutionResult.md)\<`Job`\>\>
+
+***
+
+### getRun()
+
+```ts
+getRun(runId: number): Promise<ExecutionResult<Run>>;
+```
+
+Get a specific run by ID.
+
+#### Parameters
+
+| Parameter | Type |
+| ------ | ------ |
+| `runId` | `number` |
+
+#### Returns
+
+`Promise`\<[`ExecutionResult`](TypeAlias.ExecutionResult.md)\<`Run`\>\>
+
+***
+
+### getRunOutput()
+
+```ts
+getRunOutput(runId: number): Promise<ExecutionResult<RunOutput>>;
+```
+
+Get output of a specific run.
+
+#### Parameters
+
+| Parameter | Type |
+| ------ | ------ |
+| `runId` | `number` |
+
+#### Returns
+
+`Promise`\<[`ExecutionResult`](TypeAlias.ExecutionResult.md)\<`RunOutput`\>\>
+
+***
+
+### lastRun()
+
+```ts
+lastRun(): Promise<ExecutionResult<BaseRun | undefined>>;
+```
+
+Get the most recent run for this job.
+
+#### Returns
+
+`Promise`\<[`ExecutionResult`](TypeAlias.ExecutionResult.md)\<`BaseRun` \| `undefined`\>\>
+
+***
+
+### listRuns()
+
+```ts
+listRuns(options?: {
+  limit?: number;
+}): Promise<ExecutionResult<BaseRun[]>>;
+```
+
+List runs for this job.
+
+#### Parameters
+
+| Parameter | Type |
+| ------ | ------ |
+| `options?` | \{ `limit?`: `number`; \} |
+| `options.limit?` | `number` |
+
+#### Returns
+
+`Promise`\<[`ExecutionResult`](TypeAlias.ExecutionResult.md)\<`BaseRun`[]\>\>
+
+***
+
+### runAndWait()
+
+```ts
+runAndWait(params?: Record<string, unknown>, signal?: AbortSignal): AsyncGenerator<JobRunStatus, void, unknown>;
+```
+
+Trigger and poll until completion, yielding status updates.
+
+#### Parameters
+
+| Parameter | Type |
+| ------ | ------ |
+| `params?` | `Record`\<`string`, `unknown`\> |
+| `signal?` | `AbortSignal` |
+
+#### Returns
+
+`AsyncGenerator`\<`JobRunStatus`, `void`, `unknown`\>
+
+***
+
+### runNow()
+
+```ts
+runNow(params?: Record<string, unknown>): Promise<ExecutionResult<RunNowResponse>>;
+```
+
+Trigger the configured job with validated params. Returns the run response.
+
+#### Parameters
+
+| Parameter | Type |
+| ------ | ------ |
+| `params?` | `Record`\<`string`, `unknown`\> |
+
+#### Returns
+
+`Promise`\<[`ExecutionResult`](TypeAlias.ExecutionResult.md)\<`RunNowResponse`\>\>

docs/docs/api/appkit/Interface.JobConfig.md

@@ -0,0 +1,33 @@
+# Interface: JobConfig
+
+Per-job configuration options.
+
+## Properties
+
+### params?
+
+```ts
+optional params: ZodType<Record<string, unknown>, unknown, $ZodTypeInternals<Record<string, unknown>, unknown>>;
+```
+
+Optional Zod schema for validating job parameters at runtime.
+
+***
+
+### taskType?
+
+```ts
+optional taskType: TaskType;
+```
+
+The type of task this job runs. Determines how params are mapped to the SDK request.
+
+***
+
+### waitTimeout?
+
+```ts
+optional waitTimeout: number;
+```
+
+Maximum time (ms) to poll in runAndWait before giving up. Defaults to 600 000 (10 min).

docs/docs/api/appkit/Interface.JobsConnectorConfig.md

@@ -0,0 +1,9 @@
+# Interface: JobsConnectorConfig
+
+## Properties
+
+### telemetry?
+
+```ts
+optional telemetry: TelemetryOptions;
+```

docs/docs/api/appkit/TypeAlias.JobHandle.md

@@ -0,0 +1,28 @@
+# Type Alias: JobHandle
+
+```ts
+type JobHandle = JobAPI & {
+  asUser: (req: IAppRequest) => JobAPI;
+};
+```
+
+Job handle returned by `appkit.jobs("etl")`.
+Supports OBO access via `.asUser(req)`.
+
+## Type Declaration
+
+### asUser()
+
+```ts
+asUser: (req: IAppRequest) => JobAPI;
+```
+
+#### Parameters
+
+| Parameter | Type |
+| ------ | ------ |
+| `req` | `IAppRequest` |
+
+#### Returns
+
+[`JobAPI`](Interface.JobAPI.md)

docs/docs/api/appkit/TypeAlias.JobsExport.md

@@ -0,0 +1,33 @@
+# Type Alias: JobsExport()
+
+```ts
+type JobsExport = (jobKey: string) => JobHandle;
+```
+
+Public API shape of the jobs plugin.
+Callable to select a job by key.
+
+## Parameters
+
+| Parameter | Type |
+| ------ | ------ |
+| `jobKey` | `string` |
+
+## Returns
+
+[`JobHandle`](TypeAlias.JobHandle.md)
+
+## Example
+
+```ts
+// Trigger a configured job
+const { run_id } = await appkit.jobs("etl").runNow();
+
+// Trigger and poll until completion
+for await (const status of appkit.jobs("etl").runAndWait()) {
+  console.log(status.status, status.run);
+}
+
+// OBO access
+await appkit.jobs("etl").asUser(req).runNow();
+```

docs/docs/api/appkit/index.md

@@ -35,7 +35,11 @@ plugin architecture, and React integration.
 | [DatabaseCredential](Interface.DatabaseCredential.md) | Database credentials with OAuth token for Postgres connection |
 | [EndpointConfig](Interface.EndpointConfig.md) | - |
 | [GenerateDatabaseCredentialRequest](Interface.GenerateDatabaseCredentialRequest.md) | Request parameters for generating database OAuth credentials |
+| [IJobsConfig](Interface.IJobsConfig.md) | Configuration for the Jobs plugin. |
 | [ITelemetry](Interface.ITelemetry.md) | Plugin-facing interface for OpenTelemetry instrumentation. Provides a thin abstraction over OpenTelemetry APIs for plugins. |
+| [JobAPI](Interface.JobAPI.md) | User-facing API for a single configured job. |
+| [JobConfig](Interface.JobConfig.md) | Per-job configuration options. |
+| [JobsConnectorConfig](Interface.JobsConnectorConfig.md) | - |
 | [LakebasePoolConfig](Interface.LakebasePoolConfig.md) | Configuration for creating a Lakebase connection pool |
 | [PluginManifest](Interface.PluginManifest.md) | Plugin manifest that declares metadata and resource requirements. Attached to plugin classes as a static property. Extends the shared PluginManifest with strict resource types. |
 | [RequestedClaims](Interface.RequestedClaims.md) | Optional claims for fine-grained Unity Catalog table permissions When specified, the returned token will be scoped to only the requested tables |
@@ -56,6 +60,8 @@ plugin architecture, and React integration.
 | [ConfigSchema](TypeAlias.ConfigSchema.md) | Configuration schema definition for plugin config. Re-exported from the standard JSON Schema Draft 7 types. |
 | [ExecutionResult](TypeAlias.ExecutionResult.md) | Discriminated union for plugin execution results. |
 | [IAppRouter](TypeAlias.IAppRouter.md) | Express router type for plugin route registration |
+| [JobHandle](TypeAlias.JobHandle.md) | Job handle returned by `appkit.jobs("etl")`. Supports OBO access via `.asUser(req)`. |
+| [JobsExport](TypeAlias.JobsExport.md) | Public API shape of the jobs plugin. Callable to select a job by key. |
 | [PluginData](TypeAlias.PluginData.md) | Tuple of plugin class, config, and name. Created by `toPlugin()` and passed to `createApp()`. |
 | [ResourcePermission](TypeAlias.ResourcePermission.md) | Union of all possible permission levels across all resource types. |
 | [ServingFactory](TypeAlias.ServingFactory.md) | Factory function returned by `AppKit.serving`. |