diff --git a/tap_github/repository_streams.py b/tap_github/repository_streams.py index 466ffb14..ff23b3c2 100644 --- a/tap_github/repository_streams.py +++ b/tap_github/repository_streams.py @@ -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: """ diff --git a/tap_github/streams.py b/tap_github/streams.py index 2ae5df57..5a265468 100644 --- a/tap_github/streams.py +++ b/tap_github/streams.py @@ -5,6 +5,9 @@ from tap_github.repository_streams import ( AnonymousContributorsStream, + AssigneesStream, + CollaboratorsStream, + CommitCommentsStream, CommitsStream, CommunityProfileStream, ContributorsStream, @@ -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, @@ -41,9 +42,9 @@ ) from tap_github.organization_streams import ( OrganizationStream, - TeamsStream, TeamMembersStream, TeamRolesStream, + TeamsStream, ) @@ -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 = ( @@ -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