sij/khoj
1
0
Fork 0
mirror of https://github.com/khoj-ai/khoj.git synced 2024-11-28 01:45:07 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

Explicitly use Union type for function parameters for lint checks

Browse source
This commit is contained in:
sabaimran 2023-06-29 11:44:30 -07:00
parent 601b738135
commit ab7dabe74f
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/khoj/processor/github/github_to_jsonl.py
View file

@ -1,7 +1,7 @@
# Standard Packages # Standard Packages
import logging import logging
import time import time
from typing import Dict, List from typing import Dict, List, Union
# External Packages # External Packages
import requests import requests
@ -158,7 +158,7 @@ class GithubToJsonl(TextToJsonl):
def get_commits(self, repo_url: str) -> List[Dict]: def get_commits(self, repo_url: str) -> List[Dict]:
return self._get_commits(f"{repo_url}/commits") return self._get_commits(f"{repo_url}/commits")
def _get_commits(self, commits_url: str | None) -> List[Dict]: def _get_commits(self, commits_url: Union[str, None]) -> List[Dict]:
# Get commit messages from the repository using the Github API # Get commit messages from the repository using the Github API
params = {"per_page": 100} params = {"per_page": 100}
commits = [] commits = []
@ -187,14 +187,14 @@ class GithubToJsonl(TextToJsonl):
def get_issues(self, repo_url: str) -> List[Dict]: def get_issues(self, repo_url: str) -> List[Dict]:
return self._get_issues(f"{repo_url}/issues") return self._get_issues(f"{repo_url}/issues")
def _get_issues(self, issues_url: str | None) -> List[Dict]: def _get_issues(self, issues_url: Union[str, None]) -> List[Dict]:
issues = [] issues = []
per_page = 30 per_page = 30
params = {"per_page": per_page, "state": "all"} params = {"per_page": per_page, "state": "all"}
while issues_url is not None: while issues_url is not None:
# Get the next page of issues # Get the next page of issues
response = self.session.get(issues_url, params=params, stream=True) response = self.session.get(issues_url, params=params, stream=True) # type: ignore
raw_issues = response.json() raw_issues = response.json()
# Wait for rate limit reset if needed # Wait for rate limit reset if needed
@ -218,7 +218,7 @@ class GithubToJsonl(TextToJsonl):
return issues return issues
def get_comments(self, comments_url: str | None) -> List[Dict]: def get_comments(self, comments_url: Union[str, None]) -> List[Dict]:
# By default, the number of results per page is 30. We'll keep it as-is for now. # By default, the number of results per page is 30. We'll keep it as-is for now.
comments = [] comments = []
per_page = 30 per_page = 30