Skip to content

Commit 1864052

Browse files
NischalQuTechNischalQuTech
committed
[QI2-1741] Integrate CJM API with message broadcaster
1 parent eb00c44 commit 1864052

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

86 files changed

+1009
-1028
lines changed

‎.openapi-generator/FILES‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@ compute_api_client/docs/AuthConfigApi.md
3131
compute_api_client/docs/Backend.md
3232
compute_api_client/docs/BackendApi.md
3333
compute_api_client/docs/BackendIn.md
34+
compute_api_client/docs/BackendMessage.md
3435
compute_api_client/docs/BackendPatch.md
3536
compute_api_client/docs/BackendStatus.md
3637
compute_api_client/docs/BackendType.md
@@ -116,6 +117,7 @@ compute_api_client/models/algorithm_type.py
116117
compute_api_client/models/auth_config.py
117118
compute_api_client/models/backend.py
118119
compute_api_client/models/backend_in.py
120+
compute_api_client/models/backend_message.py
119121
compute_api_client/models/backend_patch.py
120122
compute_api_client/models/backend_status.py
121123
compute_api_client/models/backend_type.py

‎README.md‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -154,6 +154,7 @@ All URIs are relative to _http://localhost_
154154
- [AuthConfig](compute_api_client/docs/AuthConfig.md)
155155
- [Backend](compute_api_client/docs/Backend.md)
156156
- [BackendIn](compute_api_client/docs/BackendIn.md)
157+
- [BackendMessage](compute_api_client/docs/BackendMessage.md)
157158
- [BackendPatch](compute_api_client/docs/BackendPatch.md)
158159
- [BackendStatus](compute_api_client/docs/BackendStatus.md)
159160
- [BackendType](compute_api_client/docs/BackendType.md)

‎compute_api_client/__init__.py‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@
5252
"AuthConfig",
5353
"Backend",
5454
"BackendIn",
55+
"BackendMessage",
5556
"BackendPatch",
5657
"BackendStatus",
5758
"BackendType",
@@ -154,6 +155,7 @@
154155
from compute_api_client.models.auth_config import AuthConfig as AuthConfig
155156
from compute_api_client.models.backend import Backend as Backend
156157
from compute_api_client.models.backend_in import BackendIn as BackendIn
158+
from compute_api_client.models.backend_message import BackendMessage as BackendMessage
157159
from compute_api_client.models.backend_patch import BackendPatch as BackendPatch
158160
from compute_api_client.models.backend_status import BackendStatus as BackendStatus
159161
from compute_api_client.models.backend_type import BackendType as BackendType

‎compute_api_client/api/algorithms_api.py‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -868,8 +868,8 @@ async def read_algorithms_algorithms_get(
868868
name: Optional[StrictStr] = None,
869869
sort_by: Annotated[Optional[StrictStr], Field(description="The field name to sort on. Prefix with '-' for descending order. E.g., '-created_on'.")] = None,
870870
latest: Annotated[Optional[StrictBool], Field(description="If True gets the most recently created object.")] = None,
871-
page: Annotated[Optional[Annotated[int, Field(strict=True, ge=1)]], Field(description="Page number")] = None,
872-
size: Annotated[Optional[Annotated[int, Field(le=100, strict=True, ge=1)]], Field(description="Page size")] = None,
871+
page: Optional[Annotated[int, Field(strict=True, ge=1)]] = None,
872+
size: Optional[Annotated[int, Field(le=100, strict=True, ge=1)]] = None,
873873
_request_timeout: Union[
874874
None,
875875
Annotated[StrictFloat, Field(gt=0)],
@@ -907,9 +907,9 @@ async def read_algorithms_algorithms_get(
907907
:type sort_by: str
908908
:param latest: If True gets the most recently created object.
909909
:type latest: bool
910-
:param page: Page number
910+
:param page:
911911
:type page: int
912-
:param size: Page size
912+
:param size:
913913
:type size: int
914914
:param _request_timeout: timeout setting for this request. If one
915915
number provided, it will be total request
@@ -980,8 +980,8 @@ async def read_algorithms_algorithms_get_with_http_info(
980980
name: Optional[StrictStr] = None,
981981
sort_by: Annotated[Optional[StrictStr], Field(description="The field name to sort on. Prefix with '-' for descending order. E.g., '-created_on'.")] = None,
982982
latest: Annotated[Optional[StrictBool], Field(description="If True gets the most recently created object.")] = None,
983-
page: Annotated[Optional[Annotated[int, Field(strict=True, ge=1)]], Field(description="Page number")] = None,
984-
size: Annotated[Optional[Annotated[int, Field(le=100, strict=True, ge=1)]], Field(description="Page size")] = None,
983+
page: Optional[Annotated[int, Field(strict=True, ge=1)]] = None,
984+
size: Optional[Annotated[int, Field(le=100, strict=True, ge=1)]] = None,
985985
_request_timeout: Union[
986986
None,
987987
Annotated[StrictFloat, Field(gt=0)],
@@ -1019,9 +1019,9 @@ async def read_algorithms_algorithms_get_with_http_info(
10191019
:type sort_by: str
10201020
:param latest: If True gets the most recently created object.
10211021
:type latest: bool
1022-
:param page: Page number
1022+
:param page:
10231023
:type page: int
1024-
:param size: Page size
1024+
:param size:
10251025
:type size: int
10261026
:param _request_timeout: timeout setting for this request. If one
10271027
number provided, it will be total request
@@ -1092,8 +1092,8 @@ async def read_algorithms_algorithms_get_without_preload_content(
10921092
name: Optional[StrictStr] = None,
10931093
sort_by: Annotated[Optional[StrictStr], Field(description="The field name to sort on. Prefix with '-' for descending order. E.g., '-created_on'.")] = None,
10941094
latest: Annotated[Optional[StrictBool], Field(description="If True gets the most recently created object.")] = None,
1095-
page: Annotated[Optional[Annotated[int, Field(strict=True, ge=1)]], Field(description="Page number")] = None,
1096-
size: Annotated[Optional[Annotated[int, Field(le=100, strict=True, ge=1)]], Field(description="Page size")] = None,
1095+
page: Optional[Annotated[int, Field(strict=True, ge=1)]] = None,
1096+
size: Optional[Annotated[int, Field(le=100, strict=True, ge=1)]] = None,
10971097
_request_timeout: Union[
10981098
None,
10991099
Annotated[StrictFloat, Field(gt=0)],
@@ -1131,9 +1131,9 @@ async def read_algorithms_algorithms_get_without_preload_content(
11311131
:type sort_by: str
11321132
:param latest: If True gets the most recently created object.
11331133
:type latest: bool
1134-
:param page: Page number
1134+
:param page:
11351135
:type page: int
1136-
:param size: Page size
1136+
:param size:
11371137
:type size: int
11381138
:param _request_timeout: timeout setting for this request. If one
11391139
number provided, it will be total request

‎compute_api_client/api/backend_api.py‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -846,8 +846,8 @@ async def read_backends_backends_get(
846846
last_heartbeat: Optional[datetime] = None,
847847
sort_by: Annotated[Optional[StrictStr], Field(description="The field name to sort on. Prefix with '-' for descending order. E.g., '-created_on'.")] = None,
848848
latest: Annotated[Optional[StrictBool], Field(description="If True gets the most recently created object.")] = None,
849-
page: Annotated[Optional[Annotated[int, Field(strict=True, ge=1)]], Field(description="Page number")] = None,
850-
size: Annotated[Optional[Annotated[int, Field(le=100, strict=True, ge=1)]], Field(description="Page size")] = None,
849+
page: Optional[Annotated[int, Field(strict=True, ge=1)]] = None,
850+
size: Optional[Annotated[int, Field(le=100, strict=True, ge=1)]] = None,
851851
_request_timeout: Union[
852852
None,
853853
Annotated[StrictFloat, Field(gt=0)],
@@ -881,9 +881,9 @@ async def read_backends_backends_get(
881881
:type sort_by: str
882882
:param latest: If True gets the most recently created object.
883883
:type latest: bool
884-
:param page: Page number
884+
:param page:
885885
:type page: int
886-
:param size: Page size
886+
:param size:
887887
:type size: int
888888
:param _request_timeout: timeout setting for this request. If one
889889
number provided, it will be total request
@@ -950,8 +950,8 @@ async def read_backends_backends_get_with_http_info(
950950
last_heartbeat: Optional[datetime] = None,
951951
sort_by: Annotated[Optional[StrictStr], Field(description="The field name to sort on. Prefix with '-' for descending order. E.g., '-created_on'.")] = None,
952952
latest: Annotated[Optional[StrictBool], Field(description="If True gets the most recently created object.")] = None,
953-
page: Annotated[Optional[Annotated[int, Field(strict=True, ge=1)]], Field(description="Page number")] = None,
954-
size: Annotated[Optional[Annotated[int, Field(le=100, strict=True, ge=1)]], Field(description="Page size")] = None,
953+
page: Optional[Annotated[int, Field(strict=True, ge=1)]] = None,
954+
size: Optional[Annotated[int, Field(le=100, strict=True, ge=1)]] = None,
955955
_request_timeout: Union[
956956
None,
957957
Annotated[StrictFloat, Field(gt=0)],
@@ -985,9 +985,9 @@ async def read_backends_backends_get_with_http_info(
985985
:type sort_by: str
986986
:param latest: If True gets the most recently created object.
987987
:type latest: bool
988-
:param page: Page number
988+
:param page:
989989
:type page: int
990-
:param size: Page size
990+
:param size:
991991
:type size: int
992992
:param _request_timeout: timeout setting for this request. If one
993993
number provided, it will be total request
@@ -1054,8 +1054,8 @@ async def read_backends_backends_get_without_preload_content(
10541054
last_heartbeat: Optional[datetime] = None,
10551055
sort_by: Annotated[Optional[StrictStr], Field(description="The field name to sort on. Prefix with '-' for descending order. E.g., '-created_on'.")] = None,
10561056
latest: Annotated[Optional[StrictBool], Field(description="If True gets the most recently created object.")] = None,
1057-
page: Annotated[Optional[Annotated[int, Field(strict=True, ge=1)]], Field(description="Page number")] = None,
1058-
size: Annotated[Optional[Annotated[int, Field(le=100, strict=True, ge=1)]], Field(description="Page size")] = None,
1057+
page: Optional[Annotated[int, Field(strict=True, ge=1)]] = None,
1058+
size: Optional[Annotated[int, Field(le=100, strict=True, ge=1)]] = None,
10591059
_request_timeout: Union[
10601060
None,
10611061
Annotated[StrictFloat, Field(gt=0)],
@@ -1089,9 +1089,9 @@ async def read_backends_backends_get_without_preload_content(
10891089
:type sort_by: str
10901090
:param latest: If True gets the most recently created object.
10911091
:type latest: bool
1092-
:param page: Page number
1092+
:param page:
10931093
:type page: int
1094-
:param size: Page size
1094+
:param size:
10951095
:type size: int
10961096
:param _request_timeout: timeout setting for this request. If one
10971097
number provided, it will be total request

‎compute_api_client/api/backend_types_api.py‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -330,8 +330,8 @@ async def read_backend_types_backend_types_get(
330330
protocol_version: Optional[StrictInt] = None,
331331
sort_by: Annotated[Optional[StrictStr], Field(description="The field name to sort on. Prefix with '-' for descending order. E.g., '-created_on'.")] = None,
332332
latest: Annotated[Optional[StrictBool], Field(description="If True gets the most recently created object.")] = None,
333-
page: Annotated[Optional[Annotated[int, Field(strict=True, ge=1)]], Field(description="Page number")] = None,
334-
size: Annotated[Optional[Annotated[int, Field(le=100, strict=True, ge=1)]], Field(description="Page size")] = None,
333+
page: Optional[Annotated[int, Field(strict=True, ge=1)]] = None,
334+
size: Optional[Annotated[int, Field(le=100, strict=True, ge=1)]] = None,
335335
_request_timeout: Union[
336336
None,
337337
Annotated[StrictFloat, Field(gt=0)],
@@ -383,9 +383,9 @@ async def read_backend_types_backend_types_get(
383383
:type sort_by: str
384384
:param latest: If True gets the most recently created object.
385385
:type latest: bool
386-
:param page: Page number
386+
:param page:
387387
:type page: int
388-
:param size: Page size
388+
:param size:
389389
:type size: int
390390
:param _request_timeout: timeout setting for this request. If one
391391
number provided, it will be total request
@@ -470,8 +470,8 @@ async def read_backend_types_backend_types_get_with_http_info(
470470
protocol_version: Optional[StrictInt] = None,
471471
sort_by: Annotated[Optional[StrictStr], Field(description="The field name to sort on. Prefix with '-' for descending order. E.g., '-created_on'.")] = None,
472472
latest: Annotated[Optional[StrictBool], Field(description="If True gets the most recently created object.")] = None,
473-
page: Annotated[Optional[Annotated[int, Field(strict=True, ge=1)]], Field(description="Page number")] = None,
474-
size: Annotated[Optional[Annotated[int, Field(le=100, strict=True, ge=1)]], Field(description="Page size")] = None,
473+
page: Optional[Annotated[int, Field(strict=True, ge=1)]] = None,
474+
size: Optional[Annotated[int, Field(le=100, strict=True, ge=1)]] = None,
475475
_request_timeout: Union[
476476
None,
477477
Annotated[StrictFloat, Field(gt=0)],
@@ -523,9 +523,9 @@ async def read_backend_types_backend_types_get_with_http_info(
523523
:type sort_by: str
524524
:param latest: If True gets the most recently created object.
525525
:type latest: bool
526-
:param page: Page number
526+
:param page:
527527
:type page: int
528-
:param size: Page size
528+
:param size:
529529
:type size: int
530530
:param _request_timeout: timeout setting for this request. If one
531531
number provided, it will be total request
@@ -610,8 +610,8 @@ async def read_backend_types_backend_types_get_without_preload_content(
610610
protocol_version: Optional[StrictInt] = None,
611611
sort_by: Annotated[Optional[StrictStr], Field(description="The field name to sort on. Prefix with '-' for descending order. E.g., '-created_on'.")] = None,
612612
latest: Annotated[Optional[StrictBool], Field(description="If True gets the most recently created object.")] = None,
613-
page: Annotated[Optional[Annotated[int, Field(strict=True, ge=1)]], Field(description="Page number")] = None,
614-
size: Annotated[Optional[Annotated[int, Field(le=100, strict=True, ge=1)]], Field(description="Page size")] = None,
613+
page: Optional[Annotated[int, Field(strict=True, ge=1)]] = None,
614+
size: Optional[Annotated[int, Field(le=100, strict=True, ge=1)]] = None,
615615
_request_timeout: Union[
616616
None,
617617
Annotated[StrictFloat, Field(gt=0)],
@@ -663,9 +663,9 @@ async def read_backend_types_backend_types_get_without_preload_content(
663663
:type sort_by: str
664664
:param latest: If True gets the most recently created object.
665665
:type latest: bool
666-
:param page: Page number
666+
:param page:
667667
:type page: int
668-
:param size: Page size
668+
:param size:
669669
:type size: int
670670
:param _request_timeout: timeout setting for this request. If one
671671
number provided, it will be total request

‎compute_api_client/api/batch_jobs_api.py‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1401,8 +1401,8 @@ async def read_batch_jobs_batch_jobs_get(
14011401
aggregated_algorithm_type: Optional[AlgorithmType] = None,
14021402
sort_by: Annotated[Optional[StrictStr], Field(description="The field name to sort on. Prefix with '-' for descending order. E.g., '-created_on'.")] = None,
14031403
latest: Annotated[Optional[StrictBool], Field(description="If True gets the most recently created object.")] = None,
1404-
page: Annotated[Optional[Annotated[int, Field(strict=True, ge=1)]], Field(description="Page number")] = None,
1405-
size: Annotated[Optional[Annotated[int, Field(le=100, strict=True, ge=1)]], Field(description="Page size")] = None,
1404+
page: Optional[Annotated[int, Field(strict=True, ge=1)]] = None,
1405+
size: Optional[Annotated[int, Field(le=100, strict=True, ge=1)]] = None,
14061406
_request_timeout: Union[
14071407
None,
14081408
Annotated[StrictFloat, Field(gt=0)],
@@ -1450,9 +1450,9 @@ async def read_batch_jobs_batch_jobs_get(
14501450
:type sort_by: str
14511451
:param latest: If True gets the most recently created object.
14521452
:type latest: bool
1453-
:param page: Page number
1453+
:param page:
14541454
:type page: int
1455-
:param size: Page size
1455+
:param size:
14561456
:type size: int
14571457
:param _request_timeout: timeout setting for this request. If one
14581458
number provided, it will be total request
@@ -1533,8 +1533,8 @@ async def read_batch_jobs_batch_jobs_get_with_http_info(
15331533
aggregated_algorithm_type: Optional[AlgorithmType] = None,
15341534
sort_by: Annotated[Optional[StrictStr], Field(description="The field name to sort on. Prefix with '-' for descending order. E.g., '-created_on'.")] = None,
15351535
latest: Annotated[Optional[StrictBool], Field(description="If True gets the most recently created object.")] = None,
1536-
page: Annotated[Optional[Annotated[int, Field(strict=True, ge=1)]], Field(description="Page number")] = None,
1537-
size: Annotated[Optional[Annotated[int, Field(le=100, strict=True, ge=1)]], Field(description="Page size")] = None,
1536+
page: Optional[Annotated[int, Field(strict=True, ge=1)]] = None,
1537+
size: Optional[Annotated[int, Field(le=100, strict=True, ge=1)]] = None,
15381538
_request_timeout: Union[
15391539
None,
15401540
Annotated[StrictFloat, Field(gt=0)],
@@ -1582,9 +1582,9 @@ async def read_batch_jobs_batch_jobs_get_with_http_info(
15821582
:type sort_by: str
15831583
:param latest: If True gets the most recently created object.
15841584
:type latest: bool
1585-
:param page: Page number
1585+
:param page:
15861586
:type page: int
1587-
:param size: Page size
1587+
:param size:
15881588
:type size: int
15891589
:param _request_timeout: timeout setting for this request. If one
15901590
number provided, it will be total request
@@ -1665,8 +1665,8 @@ async def read_batch_jobs_batch_jobs_get_without_preload_content(
16651665
aggregated_algorithm_type: Optional[AlgorithmType] = None,
16661666
sort_by: Annotated[Optional[StrictStr], Field(description="The field name to sort on. Prefix with '-' for descending order. E.g., '-created_on'.")] = None,
16671667
latest: Annotated[Optional[StrictBool], Field(description="If True gets the most recently created object.")] = None,
1668-
page: Annotated[Optional[Annotated[int, Field(strict=True, ge=1)]], Field(description="Page number")] = None,
1669-
size: Annotated[Optional[Annotated[int, Field(le=100, strict=True, ge=1)]], Field(description="Page size")] = None,
1668+
page: Optional[Annotated[int, Field(strict=True, ge=1)]] = None,
1669+
size: Optional[Annotated[int, Field(le=100, strict=True, ge=1)]] = None,
16701670
_request_timeout: Union[
16711671
None,
16721672
Annotated[StrictFloat, Field(gt=0)],
@@ -1714,9 +1714,9 @@ async def read_batch_jobs_batch_jobs_get_without_preload_content(
17141714
:type sort_by: str
17151715
:param latest: If True gets the most recently created object.
17161716
:type latest: bool
1717-
:param page: Page number
1717+
:param page:
17181718
:type page: int
1719-
:param size: Page size
1719+
:param size:
17201720
:type size: int
17211721
:param _request_timeout: timeout setting for this request. If one
17221722
number provided, it will be total request

0 commit comments

Comments
 (0)