Skip to content

Commit

Permalink
feat: unneeded prints were removed
Browse files Browse the repository at this point in the history
  • Loading branch information
scientiststwin committed Dec 20, 2023
1 parent d1536d3 commit 63e0fd4
Showing 1 changed file with 1 addition and 13 deletions.
14 changes: 1 addition & 13 deletions dags/github.py
Original file line number Diff line number Diff line change
Expand Up @@ -85,6 +85,7 @@ def get_all_organization():
# "key": ""
# }
# orgs = [rndao_org, toghether_crew_org]
# return orgs

# region organization ETL
@task
Expand Down Expand Up @@ -147,7 +148,6 @@ def extract_github_repos(organizations):
org_name=organization["organization_basic"]["name"]
)
repos = list(map(lambda repo: {"repo": repo, **organization}, repos))
print("len-repos: ", len(repos))

all_repos.extend(repos)

Expand Down Expand Up @@ -178,9 +178,6 @@ def extract_pull_requests(data):
repo_name = repo["name"]

prs = get_all_pull_requests(owner=owner, repo=repo_name)
for pr in prs:
print("pr: ", pr, end="\n\n")

new_data = {"prs": prs, **data}
return new_data

Expand All @@ -195,7 +192,6 @@ def load_pull_requests(data):
prs = data["prs"]
repository_id = data["repo"]["id"]
for pr in prs:
print("PR(pull-request): ", pr)
save_pull_request_to_neo4j(pr=pr, repository_id=repository_id)

return data
Expand Down Expand Up @@ -286,9 +282,6 @@ def extract_pr_review_comments(data):
repo_name = repo["name"]

review_comments = get_all_repo_review_comments(owner=owner, repo=repo_name)
for review_comment in review_comments:
print("review_comment: ", review_comment, end="\n\n")

return {"review_comments": review_comments, **data}

@task
Expand Down Expand Up @@ -320,9 +313,6 @@ def extract_pr_issue_comments(data):
repo_name = repo["name"]

comments = get_all_repo_issues_and_prs_comments(owner=owner, repo=repo_name)
for comment in comments:
print("comment: ", comment, end="\n\n")

return {"comments": comments, **data}

@task
Expand All @@ -336,7 +326,6 @@ def load_pr_issue_comments(data):
comments = data["comments"]
repository_id = data["repo"]["id"]

print("Len(comments): ", len(comments))
for comment in comments:
save_comment_to_neo4j(comment=comment, repository_id=repository_id)

Expand Down Expand Up @@ -384,7 +373,6 @@ def extract_issues(data):
repo_name = repo["name"]
issues = get_all_issues(owner=owner, repo=repo_name)

print("issues IN TASK: ", issues)
return {"issues": issues, **data}

@task
Expand Down

0 comments on commit 63e0fd4

Please sign in to comment.