Skip to content

Commit ef1f7e4

Browse files
committed
Moved the worker-actions to /engine/ from /api/
1 parent e8b7bee commit ef1f7e4

13 files changed

+11
-11
lines changed

packages/core/src/v3/runEngineWorker/supervisor/http.ts

+11-11
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ export class SupervisorHttpClient {
5252
async connect(body: WorkerApiConnectRequestBody) {
5353
return wrapZodFetch(
5454
WorkerApiConnectResponseBody,
55-
`${this.apiUrl}/api/v1/worker-actions/connect`,
55+
`${this.apiUrl}/engine/v1/worker-actions/connect`,
5656
{
5757
method: "POST",
5858
headers: {
@@ -67,7 +67,7 @@ export class SupervisorHttpClient {
6767
async dequeue(body: WorkerApiDequeueRequestBody) {
6868
return wrapZodFetch(
6969
WorkerApiDequeueResponseBody,
70-
`${this.apiUrl}/api/v1/worker-actions/dequeue`,
70+
`${this.apiUrl}/engine/v1/worker-actions/dequeue`,
7171
{
7272
method: "POST",
7373
headers: {
@@ -82,7 +82,7 @@ export class SupervisorHttpClient {
8282
async dequeueFromVersion(deploymentId: string, maxRunCount = 1, runnerId?: string) {
8383
return wrapZodFetch(
8484
WorkerApiDequeueResponseBody,
85-
`${this.apiUrl}/api/v1/worker-actions/deployments/${deploymentId}/dequeue?maxRunCount=${maxRunCount}`,
85+
`${this.apiUrl}/engine/v1/worker-actions/deployments/${deploymentId}/dequeue?maxRunCount=${maxRunCount}`,
8686
{
8787
headers: {
8888
...this.defaultHeaders,
@@ -95,7 +95,7 @@ export class SupervisorHttpClient {
9595
async heartbeatWorker(body: WorkerApiHeartbeatRequestBody) {
9696
return wrapZodFetch(
9797
WorkerApiHeartbeatResponseBody,
98-
`${this.apiUrl}/api/v1/worker-actions/heartbeat`,
98+
`${this.apiUrl}/engine/v1/worker-actions/heartbeat`,
9999
{
100100
method: "POST",
101101
headers: {
@@ -115,7 +115,7 @@ export class SupervisorHttpClient {
115115
) {
116116
return wrapZodFetch(
117117
WorkerApiRunHeartbeatResponseBody,
118-
`${this.apiUrl}/api/v1/worker-actions/runs/${runId}/snapshots/${snapshotId}/heartbeat`,
118+
`${this.apiUrl}/engine/v1/worker-actions/runs/${runId}/snapshots/${snapshotId}/heartbeat`,
119119
{
120120
method: "POST",
121121
headers: {
@@ -136,7 +136,7 @@ export class SupervisorHttpClient {
136136
) {
137137
return wrapZodFetch(
138138
WorkerApiRunAttemptStartResponseBody,
139-
`${this.apiUrl}/api/v1/worker-actions/runs/${runId}/snapshots/${snapshotId}/attempts/start`,
139+
`${this.apiUrl}/engine/v1/worker-actions/runs/${runId}/snapshots/${snapshotId}/attempts/start`,
140140
{
141141
method: "POST",
142142
headers: {
@@ -156,7 +156,7 @@ export class SupervisorHttpClient {
156156
) {
157157
return wrapZodFetch(
158158
WorkerApiRunAttemptCompleteResponseBody,
159-
`${this.apiUrl}/api/v1/worker-actions/runs/${runId}/snapshots/${snapshotId}/attempts/complete`,
159+
`${this.apiUrl}/engine/v1/worker-actions/runs/${runId}/snapshots/${snapshotId}/attempts/complete`,
160160
{
161161
method: "POST",
162162
headers: {
@@ -171,7 +171,7 @@ export class SupervisorHttpClient {
171171
async getLatestSnapshot(runId: string, runnerId?: string) {
172172
return wrapZodFetch(
173173
WorkerApiRunLatestSnapshotResponseBody,
174-
`${this.apiUrl}/api/v1/worker-actions/runs/${runId}/snapshots/latest`,
174+
`${this.apiUrl}/engine/v1/worker-actions/runs/${runId}/snapshots/latest`,
175175
{
176176
method: "GET",
177177
headers: {
@@ -186,7 +186,7 @@ export class SupervisorHttpClient {
186186
try {
187187
const res = await wrapZodFetch(
188188
z.unknown(),
189-
`${this.apiUrl}/api/v1/worker-actions/runs/${runId}/logs/debug`,
189+
`${this.apiUrl}/engine/v1/worker-actions/runs/${runId}/logs/debug`,
190190
{
191191
method: "POST",
192192
headers: {
@@ -209,7 +209,7 @@ export class SupervisorHttpClient {
209209
async continueRunExecution(runId: string, snapshotId: string, runnerId?: string) {
210210
return wrapZodFetch(
211211
WorkerApiContinueRunExecutionRequestBody,
212-
`${this.apiUrl}/api/v1/worker-actions/runs/${runId}/snapshots/${snapshotId}/continue`,
212+
`${this.apiUrl}/engine/v1/worker-actions/runs/${runId}/snapshots/${snapshotId}/continue`,
213213
{
214214
method: "GET",
215215
headers: {
@@ -222,7 +222,7 @@ export class SupervisorHttpClient {
222222

223223
getSuspendCompletionUrl(runId: string, snapshotId: string, runnerId?: string) {
224224
return {
225-
url: `${this.apiUrl}/api/v1/worker-actions/runs/${runId}/snapshots/${snapshotId}/suspend`,
225+
url: `${this.apiUrl}/engine/v1/worker-actions/runs/${runId}/snapshots/${snapshotId}/suspend`,
226226
headers: {
227227
...this.defaultHeaders,
228228
...this.runnerIdHeader(runnerId),

0 commit comments

Comments
 (0)