Skip to content

Commit

Permalink
Add new stream and order alphabetically
Browse files Browse the repository at this point in the history
  • Loading branch information
ericboucher committed May 18, 2022
1 parent 42310c8 commit ed77f27
Show file tree
Hide file tree
Showing 2 changed files with 30 additions and 28 deletions.
2 changes: 1 addition & 1 deletion tap_github/repository_streams.py
Original file line number Diff line number Diff line change
Expand Up @@ -1530,7 +1530,7 @@ class StargazersGraphqlStream(GitHubGraphqlStream):
parent_stream_type = RepositoryStream
state_partitioning_keys = ["repo_id"]
# The parent repository object changes if the number of stargazers changes.
ignore_parent_replication_key = True
ignore_parent_replication_key = False

def post_process(self, row: dict, context: Optional[Dict] = None) -> dict:
"""
Expand Down
56 changes: 29 additions & 27 deletions tap_github/streams.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,9 @@

from tap_github.repository_streams import (
AnonymousContributorsStream,
AssigneesStream,
CollaboratorsStream,
CommitCommentsStream,
CommitsStream,
CommunityProfileStream,
ContributorsStream,
Expand All @@ -13,26 +16,24 @@
IssueEventsStream,
IssuesStream,
LanguagesStream,
MilestonesStream,
ProjectCardsStream,
ProjectColumnsStream,
ProjectsStream,
PullRequestCommits,
PullRequestsStream,
ReadmeHtmlStream,
ReadmeStream,
ReleasesStream,
RepositoryStream,
ReviewCommentsStream,
ReviewsStream,
StargazersGraphqlStream,
StargazersStream,
StatsContributorsStream,
AssigneesStream,
CollaboratorsStream,
ReviewsStream,
ReviewCommentsStream,
ProjectsStream,
ProjectColumnsStream,
ProjectCardsStream,
PullRequestCommits,
MilestonesStream,
CommitCommentsStream,
ReleasesStream,
WorkflowsStream,
WorkflowRunJobsStream,
WorkflowRunsStream,
WorkflowsStream,
)
from tap_github.user_streams import (
StarredStream,
Expand All @@ -41,9 +42,9 @@
)
from tap_github.organization_streams import (
OrganizationStream,
TeamsStream,
TeamMembersStream,
TeamRolesStream,
TeamsStream,
)


Expand All @@ -63,34 +64,35 @@ def __init__(self, valid_queries: Set[str], streams: List[Type[Stream]]):
{"repositories", "organizations", "searches"},
[
AnonymousContributorsStream,
CommitsStream,
AssigneesStream,
CollaboratorsStream,
CommitCommentsStream,
CommitsStream,
CommunityProfileStream,
ContributorsStream,
EventsStream,
MilestonesStream,
ReleasesStream,
CollaboratorsStream,
AssigneesStream,
IssuesStream,
IssueCommentsStream,
IssueEventsStream,
IssuesStream,
LanguagesStream,
PullRequestsStream,
MilestonesStream,
ProjectCardsStream,
ProjectColumnsStream,
ProjectsStream,
PullRequestCommits,
ReviewsStream,
ReviewCommentsStream,
PullRequestsStream,
ReadmeHtmlStream,
ReadmeStream,
ReleasesStream,
RepositoryStream,
ReviewCommentsStream,
ReviewsStream,
StargazersGraphqlStream,
StargazersStream,
StatsContributorsStream,
ProjectsStream,
ProjectColumnsStream,
ProjectCardsStream,
WorkflowsStream,
WorkflowRunJobsStream,
WorkflowRunsStream,
WorkflowsStream,
],
)
USERS = (
Expand All @@ -103,7 +105,7 @@ def __init__(self, valid_queries: Set[str], streams: List[Type[Stream]]):
)
ORGANIZATIONS = (
{"organizations"},
[OrganizationStream, TeamsStream, TeamMembersStream, TeamRolesStream],
[OrganizationStream, TeamMembersStream, TeamRolesStream, TeamsStream],
)

@classmethod
Expand Down

0 comments on commit ed77f27

Please sign in to comment.