This is an automated email from the ASF dual-hosted git repository.
dheerajturaga pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new ccd96d21597 Regenerate the stale TS SDK supervisor types (#74412)
ccd96d21597 is described below
commit ccd96d21597673a1221b1728d5c0b3ac906c71d8
Author: Pierre Jeambrun <[email protected]>
AuthorDate: Wed Oct 7 19:16:12 2026 +0200
Regenerate the stale TS SDK supervisor types (#74412)
#73806 added the SetExecutionTimeout message to the supervisor wire
schema and regenerated the Go SDK models from it, but the TS SDK's
generated `src/generated/supervisor.ts` was left behind. Its
supervisor-schema static check has failed on main ever since, because
the committed types no longer match what the schema produces.
---
ts-sdk/src/generated/supervisor.ts | 104 +++++++++++++++++++++----------------
1 file changed, 58 insertions(+), 46 deletions(-)
diff --git a/ts-sdk/src/generated/supervisor.ts
b/ts-sdk/src/generated/supervisor.ts
index 76e9e727815..bb894f4eb76 100644
--- a/ts-sdk/src/generated/supervisor.ts
+++ b/ts-sdk/src/generated/supervisor.ts
@@ -558,13 +558,15 @@ 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;
@@ -572,13 +574,13 @@ 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;
@@ -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 = {
@@ -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
@@ -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 {}
/**
@@ -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.
*
@@ -1728,7 +1740,7 @@ export interface SetAssetStateStoreByUri {
*/
export interface SetRenderedFields {
rendered_fields: RenderedFields;
- type?: Type68;
+ type?: Type69;
}
export interface RenderedFields {
[k: string]: JsonValue;
@@ -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
@@ -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
@@ -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.
@@ -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
@@ -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.
@@ -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.
@@ -1814,7 +1826,7 @@ export interface SucceedTask {
*/
export interface TICount {
count: Count1;
- type?: Type75;
+ type?: Type76;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
@@ -1822,7 +1834,7 @@ export interface TICount {
*/
export interface TaskBreadcrumbsResult {
breadcrumbs: Breadcrumbs;
- type?: Type76;
+ type?: Type77;
}
/**
* Response containing the first reschedule date for a task instance.
@@ -1832,7 +1844,7 @@ export interface TaskBreadcrumbsResult {
*/
export interface TaskRescheduleStartDate {
start_date: StartDate7;
- type?: Type77;
+ type?: Type78;
}
/**
* Update a task's state.
@@ -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;
}
@@ -1859,7 +1871,7 @@ export interface TaskState {
*/
export interface TaskStateStoreResult {
value: JsonValue | null;
- type?: Type79;
+ type?: Type80;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
@@ -1867,7 +1879,7 @@ export interface TaskStateStoreResult {
*/
export interface TaskStatesResult {
task_states: TaskStates;
- type?: Type80;
+ type?: Type81;
}
export interface TaskStates {
[k: string]: unknown;
@@ -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
@@ -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.
@@ -1906,7 +1918,7 @@ 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
@@ -1914,7 +1926,7 @@ export interface UpdateHITLDetail {
*/
export interface ValidateInletsAndOutlets {
ti_id: TiId11;
- type?: Type84;
+ type?: Type85;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
@@ -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
@@ -1932,7 +1944,7 @@ export interface VariableKeysResult {
export interface VariableResult {
key: Key19;
value: Value2;
- type?: Type86;
+ type?: Type87;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
@@ -1940,7 +1952,7 @@ export interface VariableResult {
*/
export interface XComCountResponse {
len: Len;
- type?: Type87;
+ type?: Type88;
}
/**
* Response to ReadXCom request.
@@ -1951,7 +1963,7 @@ export interface XComCountResponse {
export interface XComResult {
key: Key20;
value: JsonValue | null;
- type?: Type88;
+ type?: Type89;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
@@ -1959,7 +1971,7 @@ export interface XComResult {
*/
export interface XComSequenceIndexResult {
root: JsonValue;
- type?: Type89;
+ type?: Type90;
}
/**
* This interface was referenced by `SupervisorWireSchema`'s JSON-Schema
@@ -1967,7 +1979,7 @@ export interface XComSequenceIndexResult {
*/
export interface XComSequenceSliceResult {
root: Root;
- type?: Type90;
+ type?: Type91;
}
/** Cadwyn schema version this SDK was generated against.
