Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
104 changes: 58 additions & 46 deletions ts-sdk/src/generated/supervisor.ts
Original file line number Diff line number Diff line change
Expand Up @@ -558,27 +558,29 @@ export type Type66 = "SetAssetStateStoreByName";
export type Uri9 = string;
export type Key16 = string;
export type Type67 = "SetAssetStateStoreByUri";
export type Type68 = "SetRenderedFields";
export type TimeoutSeconds = number;
export type Type68 = "SetExecutionTimeout";
export type Type69 = "SetRenderedFields";
export type RenderedMapIndex3 = string;
export type Type69 = "SetRenderedMapIndex";
export type Type70 = "SetRenderedMapIndex";
export type TiId8 = string;
export type Key17 = string;
export type ExpiresAt = string | null;
export type Type70 = "SetTaskStateStore";
export type Type71 = "SetTaskStateStore";
export type Key18 = string;
export type DagId21 = string;
export type RunId14 = string;
export type TaskId9 = string;
export type MapIndex7 = number | null;
export type DagResult1 = boolean;
export type MappedLength = number | null;
export type Type71 = "SetXCom";
export type Type72 = "SetXCom";
export type Tasks = (string | [unknown, unknown])[];
export type Type72 = "SkipDownstreamTasks";
export type Type73 = "SkipDownstreamTasks";
export type DagRelPath = string;
export type StartDate6 = string;
export type SentryIntegration = string;
export type Type73 = "StartupDetails";
export type Type74 = "StartupDetails";
export type State7 = "success";
export type EndDate7 = string;
export type TaskOutlets = AssetProfile[] | null;
Expand All @@ -588,22 +590,22 @@ export type OutletEvents =
}[]
| null;
export type RenderedMapIndex4 = string | null;
export type Type74 = "SucceedTask";
export type Type75 = "SucceedTask";
export type Count1 = number;
export type Type75 = "TICount";
export type Type76 = "TICount";
export type Breadcrumbs = {
[k: string]: unknown;
}[];
export type Type76 = "TaskBreadcrumbsResult";
export type Type77 = "TaskBreadcrumbsResult";
export type StartDate7 = string | null;
export type Type77 = "TaskRescheduleStartDate";
export type Type78 = "TaskRescheduleStartDate";
export type State8 = "failed" | "skipped" | "removed";
export type EndDate8 = string | null;
export type Type78 = "TaskState";
export type Type79 = "TaskState";
export type RenderedMapIndex5 = string | null;
export type RetryReason1 = string | null;
export type Type79 = "TaskStateStoreResult";
export type Type80 = "TaskStatesResult";
export type Type80 = "TaskStateStoreResult";
export type Type81 = "TaskStatesResult";
export type LogicalDate6 = string | null;
export type RunAfter2 = string | null;
export type Conf2 = {
Expand All @@ -614,10 +616,10 @@ export type PartitionKey7 = string | null;
export type Note2 = string | null;
export type DagId22 = string;
export type DagRunId = string;
export type Type81 = "TriggerDagRun";
export type Type82 = "TriggerDagRun";
export type TiId9 = string;
export type Note3 = string | null;
export type Type82 = "UpdateDagRunNote";
export type Type83 = "UpdateDagRunNote";
export type TiId10 = string;
/**
* @minItems 1
Expand All @@ -626,22 +628,22 @@ export type ChosenOptions = [string, ...string[]];
export type ParamsInput = {
[k: string]: unknown;
} | null;
export type Type83 = "UpdateHITLDetail";
export type Type84 = "UpdateHITLDetail";
export type TiId11 = string;
export type Type84 = "ValidateInletsAndOutlets";
export type Type85 = "ValidateInletsAndOutlets";
export type Keys = string[];
export type TotalEntries = number;
export type Type85 = "VariableKeysResult";
export type Type86 = "VariableKeysResult";
export type Key19 = string;
export type Value2 = string | null;
export type Type86 = "VariableResult";
export type Type87 = "VariableResult";
export type Len = number;
export type Type87 = "XComCountResponse";
export type Type88 = "XComCountResponse";
export type Key20 = string;
export type Type88 = "XComResult";
export type Type89 = "XComSequenceIndexResult";
export type Type89 = "XComResult";
export type Type90 = "XComSequenceIndexResult";
export type Root = JsonValue[];
export type Type90 = "XComSequenceSliceResult";
export type Type91 = "XComSequenceSliceResult";

export interface SupervisorWireSchema {}
/**
Expand Down Expand Up @@ -1720,6 +1722,16 @@ export interface SetAssetStateStoreByUri {
value: JsonValue;
type?: Type67;
}
/**
* Tell the supervisor the task's ``execution_timeout`` so it can enforce it from outside the task process.
*
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
* via the `definition` "SetExecutionTimeout".
*/
export interface SetExecutionTimeout {
timeout_seconds: TimeoutSeconds;
type?: Type68;
}
/**
* Payload for setting RTIF for a task instance.
*
Expand All @@ -1728,7 +1740,7 @@ export interface SetAssetStateStoreByUri {
*/
export interface SetRenderedFields {
rendered_fields: RenderedFields;
type?: Type68;
type?: Type69;
}
export interface RenderedFields {
[k: string]: JsonValue;
Expand All @@ -1741,7 +1753,7 @@ export interface RenderedFields {
*/
export interface SetRenderedMapIndex {
rendered_map_index: RenderedMapIndex3;
type?: Type69;
type?: Type70;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
Expand All @@ -1752,7 +1764,7 @@ export interface SetTaskStateStore {
key: Key17;
value: JsonValue;
expires_at: ExpiresAt;
type?: Type70;
type?: Type71;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
Expand All @@ -1767,7 +1779,7 @@ export interface SetXCom {
map_index?: MapIndex7;
dag_result?: DagResult1;
mapped_length?: MappedLength;
type?: Type71;
type?: Type72;
}
/**
* Update state of downstream tasks within a task instance to 'skipped', while updating current task to success state.
Expand All @@ -1777,7 +1789,7 @@ export interface SetXCom {
*/
export interface SkipDownstreamTasks {
tasks: Tasks;
type?: Type72;
type?: Type73;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
Expand All @@ -1790,7 +1802,7 @@ export interface StartupDetails {
start_date: StartDate6;
ti_context: TIRunContext;
sentry_integration: SentryIntegration;
type?: Type73;
type?: Type74;
}
/**
* Update a task's state to success. Includes task_outlets and outlet_events for registering asset events.
Expand All @@ -1804,7 +1816,7 @@ export interface SucceedTask {
task_outlets?: TaskOutlets;
outlet_events?: OutletEvents;
rendered_map_index?: RenderedMapIndex4;
type?: Type74;
type?: Type75;
}
/**
* Response containing count of Task Instances matching certain filters.
Expand All @@ -1814,15 +1826,15 @@ export interface SucceedTask {
*/
export interface TICount {
count: Count1;
type?: Type75;
type?: Type76;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
* via the `definition` "TaskBreadcrumbsResult".
*/
export interface TaskBreadcrumbsResult {
breadcrumbs: Breadcrumbs;
type?: Type76;
type?: Type77;
}
/**
* Response containing the first reschedule date for a task instance.
Expand All @@ -1832,7 +1844,7 @@ export interface TaskBreadcrumbsResult {
*/
export interface TaskRescheduleStartDate {
start_date: StartDate7;
type?: Type77;
type?: Type78;
}
/**
* Update a task's state.
Expand All @@ -1847,7 +1859,7 @@ export interface TaskRescheduleStartDate {
export interface TaskState {
state: State8;
end_date?: EndDate8;
type?: Type78;
type?: Type79;
rendered_map_index?: RenderedMapIndex5;
retry_reason?: RetryReason1;
}
Expand All @@ -1859,15 +1871,15 @@ export interface TaskState {
*/
export interface TaskStateStoreResult {
value: JsonValue | null;
type?: Type79;
type?: Type80;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
* via the `definition` "TaskStatesResult".
*/
export interface TaskStatesResult {
task_states: TaskStates;
type?: Type80;
type?: Type81;
}
export interface TaskStates {
[k: string]: unknown;
Expand All @@ -1885,7 +1897,7 @@ export interface TriggerDagRun {
note?: Note2;
dag_id: DagId22;
run_id: DagRunId;
type?: Type81;
type?: Type82;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
Expand All @@ -1894,7 +1906,7 @@ export interface TriggerDagRun {
export interface UpdateDagRunNote {
ti_id: TiId9;
note: Note3;
type?: Type82;
type?: Type83;
}
/**
* Update the response content part of an existing Human-in-the-loop response.
Expand All @@ -1906,15 +1918,15 @@ export interface UpdateHITLDetail {
ti_id: TiId10;
chosen_options: ChosenOptions;
params_input?: ParamsInput;
type?: Type83;
type?: Type84;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
* via the `definition` "ValidateInletsAndOutlets".
*/
export interface ValidateInletsAndOutlets {
ti_id: TiId11;
type?: Type84;
type?: Type85;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
Expand All @@ -1923,7 +1935,7 @@ export interface ValidateInletsAndOutlets {
export interface VariableKeysResult {
keys: Keys;
total_entries: TotalEntries;
type?: Type85;
type?: Type86;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
Expand All @@ -1932,15 +1944,15 @@ export interface VariableKeysResult {
export interface VariableResult {
key: Key19;
value: Value2;
type?: Type86;
type?: Type87;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
* via the `definition` "XComCountResponse".
*/
export interface XComCountResponse {
len: Len;
type?: Type87;
type?: Type88;
}
/**
* Response to ReadXCom request.
Expand All @@ -1951,23 +1963,23 @@ export interface XComCountResponse {
export interface XComResult {
key: Key20;
value: JsonValue | null;
type?: Type88;
type?: Type89;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
* via the `definition` "XComSequenceIndexResult".
*/
export interface XComSequenceIndexResult {
root: JsonValue;
type?: Type89;
type?: Type90;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
* via the `definition` "XComSequenceSliceResult".
*/
export interface XComSequenceSliceResult {
root: Root;
type?: Type90;
type?: Type91;
}

/** Cadwyn schema version this SDK was generated against.
Expand Down
Loading