Skip to content

Commit f0ee67d

Browse files
feat: internal: Update to new cluster api routing
1 parent c95c7e1 commit f0ee67d

File tree

10 files changed

+89
-89
lines changed

10 files changed

+89
-89
lines changed

.stats.yml

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
11
configured_endpoints: 75
2-
openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/togetherai%2Ftogetherai-f8e1988cea25f47a95ca7cf1722347162933046c684b4c1e5b346de4e24f27a0.yml
3-
openapi_spec_hash: c988b1ccf857555dad9aaca26fc0e5a3
4-
config_hash: 194c832976406fd1bf4a7d5f646a7ca0
2+
openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/togetherai%2Ftogetherai-8a76fff2b243efa52f6d90af85d9cb313bfd927d17cb30bd5e3503a3a382a050.yml
3+
openapi_spec_hash: 49b0cace7ee5a8b50781bb8bc73a2258
4+
config_hash: 87871f68de88e698f3c0c7ed6047d132

api.md

Lines changed: 27 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,22 @@ Methods:
1818
- <code title="delete /deployments/{id}">client.beta.jig.<a href="./src/resources/beta/jig/jig.ts">destroy</a>(id) -> unknown</code>
1919
- <code title="get /deployments/{id}/logs">client.beta.jig.<a href="./src/resources/beta/jig/jig.ts">retrieveLogs</a>(id, { ...params }) -> DeploymentLogs</code>
2020

21+
### Queue
22+
23+
Types:
24+
25+
- <code><a href="./src/resources/beta/jig/queue.ts">QueueRetrieveResponse</a></code>
26+
- <code><a href="./src/resources/beta/jig/queue.ts">QueueCancelResponse</a></code>
27+
- <code><a href="./src/resources/beta/jig/queue.ts">QueueMetricsResponse</a></code>
28+
- <code><a href="./src/resources/beta/jig/queue.ts">QueueSubmitResponse</a></code>
29+
30+
Methods:
31+
32+
- <code title="get /queue/status">client.beta.jig.queue.<a href="./src/resources/beta/jig/queue.ts">retrieve</a>({ ...params }) -> QueueRetrieveResponse</code>
33+
- <code title="post /queue/cancel">client.beta.jig.queue.<a href="./src/resources/beta/jig/queue.ts">cancel</a>({ ...params }) -> QueueCancelResponse</code>
34+
- <code title="get /queue/metrics">client.beta.jig.queue.<a href="./src/resources/beta/jig/queue.ts">metrics</a>({ ...params }) -> QueueMetricsResponse</code>
35+
- <code title="post /queue/submit">client.beta.jig.queue.<a href="./src/resources/beta/jig/queue.ts">submit</a>({ ...params }) -> QueueSubmitResponse</code>
36+
2137
### Volumes
2238

2339
Types:
@@ -50,22 +66,6 @@ Methods:
5066
- <code title="get /deployments/secrets">client.beta.jig.secrets.<a href="./src/resources/beta/jig/secrets.ts">list</a>() -> SecretListResponse</code>
5167
- <code title="delete /deployments/secrets/{id}">client.beta.jig.secrets.<a href="./src/resources/beta/jig/secrets.ts">delete</a>(id) -> unknown</code>
5268

53-
## Queue
54-
55-
Types:
56-
57-
- <code><a href="./src/resources/beta/queue.ts">QueueRetrieveResponse</a></code>
58-
- <code><a href="./src/resources/beta/queue.ts">QueueCancelResponse</a></code>
59-
- <code><a href="./src/resources/beta/queue.ts">QueueMetricsResponse</a></code>
60-
- <code><a href="./src/resources/beta/queue.ts">QueueSubmitResponse</a></code>
61-
62-
Methods:
63-
64-
- <code title="get /queue/status">client.beta.queue.<a href="./src/resources/beta/queue.ts">retrieve</a>({ ...params }) -> QueueRetrieveResponse</code>
65-
- <code title="post /queue/cancel">client.beta.queue.<a href="./src/resources/beta/queue.ts">cancel</a>({ ...params }) -> QueueCancelResponse</code>
66-
- <code title="get /queue/metrics">client.beta.queue.<a href="./src/resources/beta/queue.ts">metrics</a>({ ...params }) -> QueueMetricsResponse</code>
67-
- <code title="post /queue/submit">client.beta.queue.<a href="./src/resources/beta/queue.ts">submit</a>({ ...params }) -> QueueSubmitResponse</code>
68-
6969
## Clusters
7070

7171
Types:
@@ -77,12 +77,12 @@ Types:
7777

7878
Methods:
7979

80-
- <code title="post /clusters">client.beta.clusters.<a href="./src/resources/beta/clusters/clusters.ts">create</a>({ ...params }) -> Cluster</code>
81-
- <code title="get /clusters/{cluster_id}">client.beta.clusters.<a href="./src/resources/beta/clusters/clusters.ts">retrieve</a>(clusterID) -> Cluster</code>
82-
- <code title="put /clusters/{cluster_id}">client.beta.clusters.<a href="./src/resources/beta/clusters/clusters.ts">update</a>(clusterID, { ...params }) -> Cluster</code>
83-
- <code title="get /clusters">client.beta.clusters.<a href="./src/resources/beta/clusters/clusters.ts">list</a>() -> ClusterListResponse</code>
84-
- <code title="delete /clusters/{cluster_id}">client.beta.clusters.<a href="./src/resources/beta/clusters/clusters.ts">delete</a>(clusterID) -> ClusterDeleteResponse</code>
85-
- <code title="get /clusters/regions">client.beta.clusters.<a href="./src/resources/beta/clusters/clusters.ts">listRegions</a>() -> ClusterListRegionsResponse</code>
80+
- <code title="post /compute/clusters">client.beta.clusters.<a href="./src/resources/beta/clusters/clusters.ts">create</a>({ ...params }) -> Cluster</code>
81+
- <code title="get /compute/clusters/{cluster_id}">client.beta.clusters.<a href="./src/resources/beta/clusters/clusters.ts">retrieve</a>(clusterID) -> Cluster</code>
82+
- <code title="put /compute/clusters/{cluster_id}">client.beta.clusters.<a href="./src/resources/beta/clusters/clusters.ts">update</a>(clusterID, { ...params }) -> Cluster</code>
83+
- <code title="get /compute/clusters">client.beta.clusters.<a href="./src/resources/beta/clusters/clusters.ts">list</a>() -> ClusterListResponse</code>
84+
- <code title="delete /compute/clusters/{cluster_id}">client.beta.clusters.<a href="./src/resources/beta/clusters/clusters.ts">delete</a>(clusterID) -> ClusterDeleteResponse</code>
85+
- <code title="get /compute/regions">client.beta.clusters.<a href="./src/resources/beta/clusters/clusters.ts">listRegions</a>() -> ClusterListRegionsResponse</code>
8686

8787
### Storage
8888

@@ -94,11 +94,11 @@ Types:
9494

9595
Methods:
9696

97-
- <code title="post /clusters/storages">client.beta.clusters.storage.<a href="./src/resources/beta/clusters/storage.ts">create</a>({ ...params }) -> ClusterStorage</code>
98-
- <code title="get /clusters/storages/{volume_id}">client.beta.clusters.storage.<a href="./src/resources/beta/clusters/storage.ts">retrieve</a>(volumeID) -> ClusterStorage</code>
99-
- <code title="put /clusters/storages">client.beta.clusters.storage.<a href="./src/resources/beta/clusters/storage.ts">update</a>({ ...params }) -> ClusterStorage</code>
100-
- <code title="get /clusters/storages">client.beta.clusters.storage.<a href="./src/resources/beta/clusters/storage.ts">list</a>() -> StorageListResponse</code>
101-
- <code title="delete /clusters/storages/{volume_id}">client.beta.clusters.storage.<a href="./src/resources/beta/clusters/storage.ts">delete</a>(volumeID) -> StorageDeleteResponse</code>
97+
- <code title="post /compute/clusters/storage/volumes">client.beta.clusters.storage.<a href="./src/resources/beta/clusters/storage.ts">create</a>({ ...params }) -> ClusterStorage</code>
98+
- <code title="get /compute/clusters/storage/volumes/{volume_id}">client.beta.clusters.storage.<a href="./src/resources/beta/clusters/storage.ts">retrieve</a>(volumeID) -> ClusterStorage</code>
99+
- <code title="put /compute/clusters/storage/volumes">client.beta.clusters.storage.<a href="./src/resources/beta/clusters/storage.ts">update</a>({ ...params }) -> ClusterStorage</code>
100+
- <code title="get /compute/clusters/storage/volumes">client.beta.clusters.storage.<a href="./src/resources/beta/clusters/storage.ts">list</a>() -> StorageListResponse</code>
101+
- <code title="delete /compute/clusters/storage/volumes/{volume_id}">client.beta.clusters.storage.<a href="./src/resources/beta/clusters/storage.ts">delete</a>(volumeID) -> StorageDeleteResponse</code>
102102

103103
# Chat
104104

src/resources/beta/beta.ts

Lines changed: 0 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,6 @@
11
// File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
22

33
import { APIResource } from '../../core/resource';
4-
import * as QueueAPI from './queue';
5-
import {
6-
Queue,
7-
QueueCancelParams,
8-
QueueCancelResponse,
9-
QueueMetricsParams,
10-
QueueMetricsResponse,
11-
QueueRetrieveParams,
12-
QueueRetrieveResponse,
13-
QueueSubmitParams,
14-
QueueSubmitResponse,
15-
} from './queue';
164
import * as ClustersAPI from './clusters/clusters';
175
import {
186
Cluster,
@@ -37,12 +25,10 @@ import {
3725

3826
export class Beta extends APIResource {
3927
jig: JigAPI.Jig = new JigAPI.Jig(this._client);
40-
queue: QueueAPI.Queue = new QueueAPI.Queue(this._client);
4128
clusters: ClustersAPI.Clusters = new ClustersAPI.Clusters(this._client);
4229
}
4330

4431
Beta.Jig = Jig;
45-
Beta.Queue = Queue;
4632
Beta.Clusters = Clusters;
4733

4834
export declare namespace Beta {
@@ -57,18 +43,6 @@ export declare namespace Beta {
5743
type JigRetrieveLogsParams as JigRetrieveLogsParams,
5844
};
5945

60-
export {
61-
Queue as Queue,
62-
type QueueRetrieveResponse as QueueRetrieveResponse,
63-
type QueueCancelResponse as QueueCancelResponse,
64-
type QueueMetricsResponse as QueueMetricsResponse,
65-
type QueueSubmitResponse as QueueSubmitResponse,
66-
type QueueRetrieveParams as QueueRetrieveParams,
67-
type QueueCancelParams as QueueCancelParams,
68-
type QueueMetricsParams as QueueMetricsParams,
69-
type QueueSubmitParams as QueueSubmitParams,
70-
};
71-
7246
export {
7347
Clusters as Clusters,
7448
type Cluster as Cluster,

src/resources/beta/clusters/clusters.ts

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -25,42 +25,42 @@ export class Clusters extends APIResource {
2525
* management.
2626
*/
2727
create(body: ClusterCreateParams, options?: RequestOptions): APIPromise<Cluster> {
28-
return this._client.post('/clusters', { body, ...options });
28+
return this._client.post('/compute/clusters', { body, ...options });
2929
}
3030

3131
/**
3232
* Retrieve information about a specific GPU cluster.
3333
*/
3434
retrieve(clusterID: string, options?: RequestOptions): APIPromise<Cluster> {
35-
return this._client.get(path`/clusters/${clusterID}`, options);
35+
return this._client.get(path`/compute/clusters/${clusterID}`, options);
3636
}
3737

3838
/**
3939
* Update the configuration of an existing GPU cluster.
4040
*/
4141
update(clusterID: string, body: ClusterUpdateParams, options?: RequestOptions): APIPromise<Cluster> {
42-
return this._client.put(path`/clusters/${clusterID}`, { body, ...options });
42+
return this._client.put(path`/compute/clusters/${clusterID}`, { body, ...options });
4343
}
4444

4545
/**
4646
* List all GPU clusters.
4747
*/
4848
list(options?: RequestOptions): APIPromise<ClusterListResponse> {
49-
return this._client.get('/clusters', options);
49+
return this._client.get('/compute/clusters', options);
5050
}
5151

5252
/**
5353
* Delete a GPU cluster by cluster ID.
5454
*/
5555
delete(clusterID: string, options?: RequestOptions): APIPromise<ClusterDeleteResponse> {
56-
return this._client.delete(path`/clusters/${clusterID}`, options);
56+
return this._client.delete(path`/compute/clusters/${clusterID}`, options);
5757
}
5858

5959
/**
6060
* List regions and corresponding supported driver versions
6161
*/
6262
listRegions(options?: RequestOptions): APIPromise<ClusterListRegionsResponse> {
63-
return this._client.get('/clusters/regions', options);
63+
return this._client.get('/compute/regions', options);
6464
}
6565
}
6666

src/resources/beta/clusters/storage.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -14,36 +14,36 @@ export class Storage extends APIResource {
1414
* performance for shared storage.
1515
*/
1616
create(body: StorageCreateParams, options?: RequestOptions): APIPromise<ClusterStorage> {
17-
return this._client.post('/clusters/storages', { body, ...options });
17+
return this._client.post('/compute/clusters/storage/volumes', { body, ...options });
1818
}
1919

2020
/**
2121
* Retrieve information about a specific shared volume.
2222
*/
2323
retrieve(volumeID: string, options?: RequestOptions): APIPromise<ClusterStorage> {
24-
return this._client.get(path`/clusters/storages/${volumeID}`, options);
24+
return this._client.get(path`/compute/clusters/storage/volumes/${volumeID}`, options);
2525
}
2626

2727
/**
2828
* Update the configuration of an existing shared volume.
2929
*/
3030
update(body: StorageUpdateParams, options?: RequestOptions): APIPromise<ClusterStorage> {
31-
return this._client.put('/clusters/storages', { body, ...options });
31+
return this._client.put('/compute/clusters/storage/volumes', { body, ...options });
3232
}
3333

3434
/**
3535
* List all shared volumes.
3636
*/
3737
list(options?: RequestOptions): APIPromise<StorageListResponse> {
38-
return this._client.get('/clusters/storages', options);
38+
return this._client.get('/compute/clusters/storage/volumes', options);
3939
}
4040

4141
/**
4242
* Delete a shared volume. Note that if this volume is attached to a cluster,
4343
* deleting will fail.
4444
*/
4545
delete(volumeID: string, options?: RequestOptions): APIPromise<StorageDeleteResponse> {
46-
return this._client.delete(path`/clusters/storages/${volumeID}`, options);
46+
return this._client.delete(path`/compute/clusters/storage/volumes/${volumeID}`, options);
4747
}
4848
}
4949

src/resources/beta/index.ts

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -20,14 +20,3 @@ export {
2020
type JigDeployParams,
2121
type JigRetrieveLogsParams,
2222
} from './jig/index';
23-
export {
24-
Queue,
25-
type QueueRetrieveResponse,
26-
type QueueCancelResponse,
27-
type QueueMetricsResponse,
28-
type QueueSubmitResponse,
29-
type QueueRetrieveParams,
30-
type QueueCancelParams,
31-
type QueueMetricsParams,
32-
type QueueSubmitParams,
33-
} from './queue';

src/resources/beta/jig/index.ts

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,17 @@ export {
1010
type JigDeployParams,
1111
type JigRetrieveLogsParams,
1212
} from './jig';
13+
export {
14+
Queue,
15+
type QueueRetrieveResponse,
16+
type QueueCancelResponse,
17+
type QueueMetricsResponse,
18+
type QueueSubmitResponse,
19+
type QueueRetrieveParams,
20+
type QueueCancelParams,
21+
type QueueMetricsParams,
22+
type QueueSubmitParams,
23+
} from './queue';
1324
export {
1425
Secrets,
1526
type Secret,

src/resources/beta/jig/jig.ts

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,18 @@
11
// File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
22

33
import { APIResource } from '../../../core/resource';
4+
import * as QueueAPI from './queue';
5+
import {
6+
Queue,
7+
QueueCancelParams,
8+
QueueCancelResponse,
9+
QueueMetricsParams,
10+
QueueMetricsResponse,
11+
QueueRetrieveParams,
12+
QueueRetrieveResponse,
13+
QueueSubmitParams,
14+
QueueSubmitResponse,
15+
} from './queue';
416
import * as SecretsAPI from './secrets';
517
import {
618
Secret,
@@ -24,6 +36,7 @@ import { RequestOptions } from '../../../internal/request-options';
2436
import { path } from '../../../internal/utils/path';
2537

2638
export class Jig extends APIResource {
39+
queue: QueueAPI.Queue = new QueueAPI.Queue(this._client);
2740
volumes: VolumesAPI.Volumes = new VolumesAPI.Volumes(this._client);
2841
secrets: SecretsAPI.Secrets = new SecretsAPI.Secrets(this._client);
2942

@@ -698,6 +711,7 @@ export interface JigRetrieveLogsParams {
698711
replica_id?: string;
699712
}
700713

714+
Jig.Queue = Queue;
701715
Jig.Volumes = Volumes;
702716
Jig.Secrets = Secrets;
703717

@@ -712,6 +726,18 @@ export declare namespace Jig {
712726
type JigRetrieveLogsParams as JigRetrieveLogsParams,
713727
};
714728

729+
export {
730+
Queue as Queue,
731+
type QueueRetrieveResponse as QueueRetrieveResponse,
732+
type QueueCancelResponse as QueueCancelResponse,
733+
type QueueMetricsResponse as QueueMetricsResponse,
734+
type QueueSubmitResponse as QueueSubmitResponse,
735+
type QueueRetrieveParams as QueueRetrieveParams,
736+
type QueueCancelParams as QueueCancelParams,
737+
type QueueMetricsParams as QueueMetricsParams,
738+
type QueueSubmitParams as QueueSubmitParams,
739+
};
740+
715741
export {
716742
Volumes as Volumes,
717743
type VolumesAPIVolume as Volume,
Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
// File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
22

3-
import { APIResource } from '../../core/resource';
4-
import { APIPromise } from '../../core/api-promise';
5-
import { RequestOptions } from '../../internal/request-options';
3+
import { APIResource } from '../../../core/resource';
4+
import { APIPromise } from '../../../core/api-promise';
5+
import { RequestOptions } from '../../../internal/request-options';
66

77
export class Queue extends APIResource {
88
/**

tests/api-resources/beta/queue.test.ts renamed to tests/api-resources/beta/jig/queue.test.ts

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ const client = new Together({
99

1010
describe('resource queue', () => {
1111
test('retrieve: only required params', async () => {
12-
const responsePromise = client.beta.queue.retrieve({ model: 'model', request_id: 'request_id' });
12+
const responsePromise = client.beta.jig.queue.retrieve({ model: 'model', request_id: 'request_id' });
1313
const rawResponse = await responsePromise.asResponse();
1414
expect(rawResponse).toBeInstanceOf(Response);
1515
const response = await responsePromise;
@@ -20,11 +20,11 @@ describe('resource queue', () => {
2020
});
2121

2222
test('retrieve: required and optional params', async () => {
23-
const response = await client.beta.queue.retrieve({ model: 'model', request_id: 'request_id' });
23+
const response = await client.beta.jig.queue.retrieve({ model: 'model', request_id: 'request_id' });
2424
});
2525

2626
test('cancel: only required params', async () => {
27-
const responsePromise = client.beta.queue.cancel({ model: 'model', request_id: 'request_id' });
27+
const responsePromise = client.beta.jig.queue.cancel({ model: 'model', request_id: 'request_id' });
2828
const rawResponse = await responsePromise.asResponse();
2929
expect(rawResponse).toBeInstanceOf(Response);
3030
const response = await responsePromise;
@@ -35,11 +35,11 @@ describe('resource queue', () => {
3535
});
3636

3737
test('cancel: required and optional params', async () => {
38-
const response = await client.beta.queue.cancel({ model: 'model', request_id: 'request_id' });
38+
const response = await client.beta.jig.queue.cancel({ model: 'model', request_id: 'request_id' });
3939
});
4040

4141
test('metrics: only required params', async () => {
42-
const responsePromise = client.beta.queue.metrics({ model: 'model' });
42+
const responsePromise = client.beta.jig.queue.metrics({ model: 'model' });
4343
const rawResponse = await responsePromise.asResponse();
4444
expect(rawResponse).toBeInstanceOf(Response);
4545
const response = await responsePromise;
@@ -50,11 +50,11 @@ describe('resource queue', () => {
5050
});
5151

5252
test('metrics: required and optional params', async () => {
53-
const response = await client.beta.queue.metrics({ model: 'model' });
53+
const response = await client.beta.jig.queue.metrics({ model: 'model' });
5454
});
5555

5656
test('submit: only required params', async () => {
57-
const responsePromise = client.beta.queue.submit({
57+
const responsePromise = client.beta.jig.queue.submit({
5858
model: 'model',
5959
payload: { foo: 'bar' },
6060
});
@@ -68,7 +68,7 @@ describe('resource queue', () => {
6868
});
6969

7070
test('submit: required and optional params', async () => {
71-
const response = await client.beta.queue.submit({
71+
const response = await client.beta.jig.queue.submit({
7272
model: 'model',
7373
payload: { foo: 'bar' },
7474
info: { foo: 'bar' },

0 commit comments

Comments
 (0)