Skip to content
Merged
Show file tree
Hide file tree
Changes from 3 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 8 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -162,3 +162,11 @@ playground/cloudfunction.zip
# as its generated with terraform
.test-infra/metrics/sync/github/github_runs_prefetcher/code.zip
.venv/


beam-env/
build/
*.pyc
__pycache__/
*.pyd
*.egg-info/
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think most of these are taken care of already in this file

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks! I’ll revert the .gitignore changes since they are already covered.

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I’ve reverted the .gitignore changes. Please let me know if anything else needs adjustment.

Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,6 @@
from .groupby_two_exprs import groupby_two_exprs



class UnorderedList(object):
def __init__(self, contents):
self._contents = list(contents)
Expand Down
5 changes: 5 additions & 0 deletions sdks/python/apache_beam/runners/worker/operations.py
Original file line number Diff line number Diff line change
Expand Up @@ -1234,6 +1234,11 @@ def flush(self, target):


class PGBKCVOperation(Operation):
"""Partial group-by-key operation.

This operation handles grouped values with
a combine function applied.
"""
def __init__(
self, name_context, spec, counter_factory, state_sampler, windowing=None):
super(PGBKCVOperation,
Expand Down
Loading