diff --git a/tap_github/repository_streams.py b/tap_github/repository_streams.py index 95e310c4..43eadecd 100644 --- a/tap_github/repository_streams.py +++ b/tap_github/repository_streams.py @@ -880,9 +880,15 @@ def post_process(self, row: dict, context: Optional[dict] = None) -> dict: is used to compare to the `since` argument that the endpoint supports. """ row["commit_timestamp"] = row["commit"]["committer"]["date"] + # add some context info to help downstream processing + assert context is not None, "CommitsStream was called without context" + row["repo"] = context["repo"] + row["org"] = context["org"] return row schema = th.PropertiesList( + th.Property("org", th.StringType), + th.Property("repo", th.StringType), th.Property("node_id", th.StringType), th.Property("url", th.StringType), th.Property("sha", th.StringType),