Skip to content
Merged
Show file tree
Hide file tree
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
4 changes: 2 additions & 2 deletions simple_ado/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -181,7 +181,7 @@ def verify_access(self) -> bool:
"""

request_url = (
self.http_client.api_endpoint(is_default_collection=False) + "/projects?api-version=6.0"
self.http_client.api_endpoint(is_default_collection=False) + "/projects?api-version=7.1"
)

try:
Expand Down Expand Up @@ -221,7 +221,7 @@ def create_pull_request(
self.log.debug("Creating pull request")

request_url = f"{self.http_client.api_endpoint(project_id=project_id)}/git/repositories/{repository_id}"
request_url += "/pullRequests?api-version=5.1"
request_url += "/pullRequests?api-version=7.1"

body: dict[str, Any] = {
"sourceRefName": _canonicalize_branch_name(source_branch),
Expand Down
4 changes: 2 additions & 2 deletions simple_ado/audit.py
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ def get_actions(self, area_name: str | None = None) -> list[AuditActionInfo]:

self.log.debug("Getting audit actions")

parameters = {"api-version": "6.0-preview.1"}
parameters = {"api-version": "7.1-preview.1"}

if area_name:
parameters["areaName"] = area_name
Expand Down Expand Up @@ -65,7 +65,7 @@ def query(
:returns: The queried log
"""

parameters = {"api-version": "6.0-preview.1"}
parameters = {"api-version": "7.1-preview.1"}

if start_time:
parameters["startTime"] = start_time.strftime("%Y-%m-%dT%H:%M:%S.000Z")
Expand Down
14 changes: 7 additions & 7 deletions simple_ado/builds.py
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ def queue_build(
"""

request_url = (
f"{self.http_client.api_endpoint(project_id=project_id)}/build/builds?api-version=4.1"
f"{self.http_client.api_endpoint(project_id=project_id)}/build/builds?api-version=7.1"
)
variable_json = json.dumps(variables)

Expand Down Expand Up @@ -97,7 +97,7 @@ def build_info(self, *, project_id: str, build_id: int) -> ADOResponse:

request_url = (
self.http_client.api_endpoint(project_id=project_id)
+ f"/build/builds/{build_id}?api-version=4.1"
+ f"/build/builds/{build_id}?api-version=7.1"
)
response = self.http_client.get(request_url)
return self.http_client.decode_response(response)
Expand All @@ -121,7 +121,7 @@ def get_builds(
request_url = self.http_client.api_endpoint(project_id=project_id) + "/build/builds/?"

parameters = {
"api-version": "4.1",
"api-version": "7.1",
}

if definitions:
Expand Down Expand Up @@ -180,7 +180,7 @@ def get_artifact_info(

parameters = {
"artifactName": artifact_name,
"api-version": "4.1",
"api-version": "7.1",
}

request_url = f"{self.http_client.api_endpoint(project_id=project_id)}/build/builds/{build_id}/artifacts?"
Expand Down Expand Up @@ -229,7 +229,7 @@ def download_artifact(
parameters = {
"artifactName": artifact_name,
"$format": "zip",
"api-version": "4.1",
"api-version": "7.1",
}

request_url = f"{self.http_client.api_endpoint(project_id=project_id)}/build/builds/{build_id}/artifacts?"
Expand Down Expand Up @@ -423,7 +423,7 @@ def get_definitions(self, *, project_id: str) -> ADOResponse:

request_url = (
self.http_client.api_endpoint(project_id=project_id)
+ "/build/definitions?api-version=6.0"
+ "/build/definitions?api-version=7.1"
)

response = self.http_client.get(request_url)
Expand All @@ -441,7 +441,7 @@ def get_definition(self, *, project_id: str, definition_id: int) -> ADOResponse:

request_url = (
self.http_client.api_endpoint(project_id=project_id)
+ f"/build/definitions/{definition_id}?api-version=6.0"
+ f"/build/definitions/{definition_id}?api-version=7.1"
)

response = self.http_client.get(request_url)
Expand Down
4 changes: 2 additions & 2 deletions simple_ado/endpoints.py
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ def get_endpoints(self, project_id: str, *, endpoint_type: str | None = None) ->
self.http_client.api_endpoint(project_id=project_id) + "/serviceendpoint/endpoints?"
)

parameters = {"api-version": "6.0-preview.4"}
parameters = {"api-version": "7.1"}

if endpoint_type:
parameters["type"] = endpoint_type
Expand All @@ -63,7 +63,7 @@ def get_usage_history(
+ f"/serviceendpoint/{endpoint_id}/executionhistory?"
)

parameters: dict[str, Any] = {"api-version": "6.0-preview.1"}
parameters: dict[str, Any] = {"api-version": "7.1"}

if not top or top < 50:
parameters["top"] = top
Expand Down
26 changes: 13 additions & 13 deletions simple_ado/git.py
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ def all_repositories(self, project_id: str) -> ADOResponse:
:returns: The ADO response with the data in it
"""
self.log.debug("Getting repositories")
request_url = f"{self.http_client.api_endpoint(project_id=project_id)}/git/repositories/?api-version=1.0"
request_url = f"{self.http_client.api_endpoint(project_id=project_id)}/git/repositories/?api-version=7.1"
response = self.http_client.get(request_url)
response_data = self.http_client.decode_response(response)
return self.http_client.extract_value(response_data)
Expand All @@ -100,7 +100,7 @@ def get_repository(self, *, project_id: str, repository_id: str) -> ADOResponse:
self.log.debug(f"Getting repository {repository_id}")
request_url = (
f"{self.http_client.api_endpoint(project_id=project_id)}/git/"
+ f"repositories/{repository_id}?api-version=6.0"
+ f"repositories/{repository_id}?api-version=7.1"
)
response = self.http_client.get(request_url)
return self.http_client.decode_response(response)
Expand All @@ -124,7 +124,7 @@ def get_status(self, *, sha: str, project_id: str, repository_id: str) -> ADORes

request_url = (
self.http_client.api_endpoint(project_id=project_id)
+ f"/git/repositories/{repository_id}/commits/{sha}/statuses?api-version=2.1"
+ f"/git/repositories/{repository_id}/commits/{sha}/statuses?api-version=7.1"
)

response = self.http_client.get(request_url)
Expand Down Expand Up @@ -171,7 +171,7 @@ def set_status(
self.http_client.api_endpoint(project_id=project_id)
+ f"/git/repositories/{repository_id}/commits/{sha}/"
)
request_url += "statuses?api-version=2.1"
request_url += "statuses?api-version=7.1"

body = {
"state": state.value,
Expand Down Expand Up @@ -215,7 +215,7 @@ def diff_between_commits(

while True:
parameters = {
"api-version": "5.1",
"api-version": "7.1",
"baseVersionType": "commit",
"baseVersion": base_commit,
"targetVersionType": "commit",
Expand Down Expand Up @@ -272,7 +272,7 @@ def download_zip(
"versionDescriptor[version]": branch,
"resolveLfs": "true",
"$format": "zip",
"api-version": "5.0-preview.1",
"api-version": "7.1",
}

request_url += urllib.parse.urlencode(parameters)
Expand Down Expand Up @@ -381,7 +381,7 @@ def get_refs(
if len(parameters) > 0:
request_url += "&"

request_url += "api-version=5.0"
request_url += "api-version=7.1"

response = self.http_client.get(request_url)
response_data = self.http_client.decode_response(response)
Expand All @@ -406,7 +406,7 @@ def get_stats_for_branch(
self.log.debug("Getting stats")

request_url = f"{self.http_client.api_endpoint(project_id=project_id)}/git/repositories/{repository_id}"
request_url += f"/stats/branches?name={branch_name}&api-version=6.0"
request_url += f"/stats/branches?name={branch_name}&api-version=7.1"

response = self.http_client.get(request_url)
return self.http_client.decode_response(response)
Expand Down Expand Up @@ -435,7 +435,7 @@ def get_commit(
self.log.debug(f"Getting commit: {commit_id}")

request_url = f"{self.http_client.api_endpoint(project_id=project_id)}/git/repositories/{repository_id}"
request_url += f"/commits/{commit_id}?api-version=5.0"
request_url += f"/commits/{commit_id}?api-version=7.1"

if change_count:
request_url += f"&changeCount={change_count}"
Expand All @@ -462,7 +462,7 @@ def update_refs(
self.log.debug("Updating references")

request_url = f"{self.http_client.api_endpoint(project_id=project_id)}/git/repositories/{repository_id}"
request_url += "/refs?api-version=5.0"
request_url += "/refs?api-version=7.1"

data = [update.json_data() for update in updates]

Expand Down Expand Up @@ -551,7 +551,7 @@ def get_item(

request_url = f"{self.http_client.api_endpoint(project_id=project_id)}/git/repositories/{repository_id}/items?"

parameters: dict[str, Any] = {"api-version": "5.1", "$format": "json"}
parameters: dict[str, Any] = {"api-version": "7.1", "$format": "json"}

if not scope_path and not path:
raise ADOException("Either path or scope_path must be set")
Expand Down Expand Up @@ -752,7 +752,7 @@ def get_blob(
request_url += f"/git/repositories/{repository_id}/blobs/{blob_id}?"

parameters: dict[str, Any] = {
"api-version": "5.1",
"api-version": "7.1",
}

if blob_format is not None:
Expand Down Expand Up @@ -806,7 +806,7 @@ def get_blobs(
request_url = self.http_client.api_endpoint(
is_default_collection=False, project_id=project_id
)
request_url += f"/git/repositories/{repository_id}/blobs?api-version=5.1"
request_url += f"/git/repositories/{repository_id}/blobs?api-version=7.1"

if os.path.exists(output_path):
raise FileExistsError("The output path already exists")
Expand Down
14 changes: 7 additions & 7 deletions simple_ado/graph.py
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ def get_scope_descriptors(self, storage_key: str) -> ADOResponse:
"""

request_url = f"{self.http_client.graph_endpoint()}/graph/descriptors/{storage_key}"
request_url += "/?api-version=6.0-preview.1"
request_url += "/?api-version=7.1-preview.1"
response = self.http_client.get(request_url)
return self.http_client.decode_response(response)

Expand All @@ -43,7 +43,7 @@ def get_storage_key(self, subject_descriptor: str) -> ADOResponse:
"""

request_url = f"{self.http_client.graph_endpoint()}/graph/storagekeys/{subject_descriptor}"
request_url += "/?api-version=6.0-preview.1"
request_url += "/?api-version=7.1-preview.1"
response = self.http_client.get(request_url)
return self.http_client.decode_response(response)

Expand All @@ -56,7 +56,7 @@ def lookup_subjects(self, subject_descriptors: list[str]) -> list[Any]:
"""

request_url = f"{self.http_client.graph_endpoint()}/graph/subjectlookup"
request_url += "/?api-version=6.0-preview.1"
request_url += "/?api-version=7.1-preview.1"

data = {"lookupKeys": [{"descriptor": descriptor} for descriptor in subject_descriptors]}

Expand All @@ -72,7 +72,7 @@ def list_groups(self, *, scope_descriptor: str | None = None) -> list[Any]:
:returns: The ADO response with the data in it
"""

request_url = f"{self.http_client.graph_endpoint()}/graph/groups?api-version=5.1-preview.1"
request_url = f"{self.http_client.graph_endpoint()}/graph/groups?api-version=7.1-preview.1"

if scope_descriptor:
request_url += f"&scopeDescriptor={scope_descriptor}"
Expand Down Expand Up @@ -106,7 +106,7 @@ def get_group(self, descriptor: str) -> ADOResponse:
"""

request_url = f"{self.http_client.graph_endpoint()}/graph/groups"
request_url += f"/{descriptor}?api-version=5.1-preview.1"
request_url += f"/{descriptor}?api-version=7.1-preview.1"
response = self.http_client.get(request_url)
return self.http_client.decode_response(response)

Expand All @@ -119,7 +119,7 @@ def get_user(self, descriptor: str) -> ADOResponse:
"""

request_url = f"{self.http_client.graph_endpoint()}/graph/users"
request_url += f"/{descriptor}?api-version=5.1-preview.1"
request_url += f"/{descriptor}?api-version=7.1-preview.1"
response = self.http_client.get(request_url)
return self.http_client.decode_response(response)

Expand All @@ -130,7 +130,7 @@ def get_users(self) -> ADOResponse:
"""

request_url = f"{self.http_client.graph_endpoint()}/graph/users"
request_url += "?api-version=6.0-preview.1"
request_url += "?api-version=7.1-preview.1"
response = self.http_client.get(request_url)
return self.http_client.decode_response(response)

Expand Down
2 changes: 1 addition & 1 deletion simple_ado/identities.py
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ def search(self, identity: str) -> list[dict[str, Any]]:

request_url = self.http_client.graph_endpoint()
request_url += f"/identities?searchFilter=General&filterValue={identity}"
request_url += "&queryMembership=None&api-version=6.0"
request_url += "&queryMembership=None&api-version=7.1"

response = self.http_client.get(request_url)
response_data = self.http_client.decode_response(response)
Expand Down
6 changes: 3 additions & 3 deletions simple_ado/pipelines.py
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,7 @@ def get_top_ten_thousand_runs(self, *, project_id: str, pipeline_id: int) -> ADO

request_url = (
self.http_client.api_endpoint(project_id=project_id)
+ f"/pipelines/{pipeline_id}/runs?api-version=6.0-preview.1"
+ f"/pipelines/{pipeline_id}/runs?api-version=7.1"
)

response = self.http_client.get(request_url)
Expand All @@ -155,7 +155,7 @@ def get_run(self, *, project_id: str, pipeline_id: int, run_id: int) -> ADORespo

request_url = (
self.http_client.api_endpoint(project_id=project_id)
+ f"/pipelines/{pipeline_id}/runs/{run_id}?api-version=6.0-preview.1"
+ f"/pipelines/{pipeline_id}/runs/{run_id}?api-version=7.1"
)

response = self.http_client.get(request_url)
Expand Down Expand Up @@ -191,7 +191,7 @@ def run_pipeline(

request_url = (
self.http_client.api_endpoint(project_id=project_id)
+ f"/pipelines/{pipeline_id}/runs?api-version=6.1-preview.1"
+ f"/pipelines/{pipeline_id}/runs?api-version=7.1"
)

if pipeline_version:
Expand Down
10 changes: 5 additions & 5 deletions simple_ado/pools.py
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ def get_pools(
request_url = self.http_client.api_endpoint(is_default_collection=False)
request_url += "/distributedtask/pools?"

parameters = {"api-version": "5.1"}
parameters = {"api-version": "7.1"}

if pool_name:
parameters["poolName"] = pool_name
Expand Down Expand Up @@ -91,7 +91,7 @@ def get_agents(
"includeCapabilities": include_capabilities,
"includeAssignedRequest": include_assigned_request,
"includeLastCompletedRequest": include_last_completed_request,
"api-version": "5.1",
"api-version": "7.1",
}

if agent_name:
Expand All @@ -113,7 +113,7 @@ def get_agent(self, *, pool_id: int, agent_id: int) -> ADOResponse:
"""

request_url = self.http_client.api_endpoint(is_default_collection=False)
request_url += f"/distributedtask/pools/{pool_id}/agents/{agent_id}?api-version=5.1"
request_url += f"/distributedtask/pools/{pool_id}/agents/{agent_id}?api-version=7.1"

response = self.http_client.get(request_url)
return self.http_client.decode_response(response)
Expand All @@ -131,7 +131,7 @@ def update_agent(
"""

request_url = self.http_client.api_endpoint(is_default_collection=False)
request_url += f"/distributedtask/pools/{pool_id}/agents/{agent_id}?api-version=5.1"
request_url += f"/distributedtask/pools/{pool_id}/agents/{agent_id}?api-version=7.1"

response = self.http_client.patch(request_url, json_data=agent_data)
return self.http_client.decode_response(response)
Expand Down Expand Up @@ -164,7 +164,7 @@ def update_agent_capabilities(

request_url = self.http_client.api_endpoint(is_default_collection=False)
request_url += (
f"/distributedtask/pools/{pool_id}/agents/{agent_id}/usercapabilities?api-version=5.1"
f"/distributedtask/pools/{pool_id}/agents/{agent_id}/usercapabilities?api-version=7.1"
)

response = self.http_client.put(request_url, json_data=capabilities)
Expand Down
Loading