-
Notifications
You must be signed in to change notification settings - Fork 326
Feature: Write to branches #941
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
@sungwy @kevinjqliu |
Fixed another bug. Please review whenever you get some time. |
Thanks for the contribution! I'll take a look. |
I have mostly tried to cover all edge cases. I also agree with your concern. |
Hey @kevinjqliu |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the PR! And sorry for the delay, I was running the 0.8.0 release.
Generally LGTM, I left a comment about add more tests integrating with Spark
Thank you for the review @kevinjqliu |
@kevinjqliu What are the next steps to get this merged? |
Hey @Fokko |
Hey @vinjai, did you get a chance to fix those conflicts? 🙂 |
Thanks @SebastienN15 — I’ll review your commit and take it forward from there. |
Identified and fixed a bug related to empty tables. |
Hey @Fokko |
Hey @Fokko ServerError: NoSuchBucketException: The specified bucket does not exist (Service: S3, Status Code: 404, Request ID: 18436A88DE8BCC82, Extended Request ID: dd9025bab4ad464b049177c95eb6ebf374d3b3fd1af9251148b658df7ac2e3e8) (SDK Attempt Count: 1) I ran the same tests locally with Python 3.9.6, and they passed without issues. |
Hey @Fokko |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks @vinjai for working on this, and sorry for the long wait. I think this looks great, and let's move this forward 👍
pyiceberg/table/__init__.py
Outdated
if branch is None: | ||
files = self._scan(row_filter=delete_filter, case_sensitive=case_sensitive).plan_files() | ||
else: | ||
files = self._scan(row_filter=delete_filter, case_sensitive=case_sensitive).use_ref(branch).plan_files() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Maybe in a subsequent PR we can pass in the ref to the constructor 👍
@vinjai I'm sorry, can you resolve the conflicts once more? I'll merge right after |
Hey @vinjai, would you be able to resolve the conflicts? I would love to see this PR merged 🙏 |
Hey @Fokko
The same error is coming on the main branch too. Any idea on how to resolve this? |
Hey @Fokko, I tried the tests on a different machine. The tests are running fine. Thanks |
@vinjai Thanks, let's move this forward. Thanks @SebastienN15 for pinging me on this matter :) |
Fixes: apache#306 --------- Co-authored-by: Kevin Liu <kevin.jq.liu@gmail.com>
Fixes: #306