Skip to content

GH-39574: [Go] Enable PollFlightInfo in Flight RPC#39575

Merged
lidavidm merged 2 commits intoapache:mainfrom
lidavidm:gh39574
Jan 19, 2024
Merged

GH-39574: [Go] Enable PollFlightInfo in Flight RPC#39575
lidavidm merged 2 commits intoapache:mainfrom
lidavidm:gh39574

Conversation

@lidavidm
Copy link
Copy Markdown
Member

@lidavidm lidavidm commented Jan 11, 2024

Rationale for this change

It's impossible to use the current bindings with PollFlightInfo. Required for apache/arrow-adbc#1457.

What changes are included in this PR?

Add new methods that expose PollFlightInfo.

Are these changes tested?

Yes

Are there any user-facing changes?

Adds new methods.

@lidavidm lidavidm marked this pull request as ready for review January 12, 2024 20:21
@lidavidm lidavidm requested a review from zeroshade as a code owner January 12, 2024 20:21
@lidavidm
Copy link
Copy Markdown
Member Author

CC @zeroshade

Comment on lines +1063 to +1065
if _, err = pstream.Recv(); err != nil && err != io.EOF {
return nil, err
}
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

didn't we have a helper function that did this?

Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

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

I don't think so. This is basically verbatim from the synchronous version of this method.

Comment on lines +1067 to +1069
return p.client.Client.PollFlightInfo(ctx, desc, opts...)
}
return p.client.Client.PollFlightInfo(ctx, retryDescriptor, opts...)
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

couldn't we condense this by doing retryDescriptor = desc and not duplicate the line?

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

Either that, or can we simplify and early return if retryDescriptor != nil { return p.client.Client.PollFlightInfo.... }

Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

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

Updated

@github-actions github-actions bot added awaiting changes Awaiting changes and removed awaiting committer review Awaiting committer review labels Jan 18, 2024
Copy link
Copy Markdown
Member

@zeroshade zeroshade left a comment

Choose a reason for hiding this comment

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

Just a few nitpicks but otherwise looks good to me

@github-actions github-actions bot added awaiting merge Awaiting merge awaiting changes Awaiting changes and removed awaiting changes Awaiting changes awaiting merge Awaiting merge labels Jan 18, 2024
@github-actions github-actions bot added awaiting change review Awaiting change review awaiting changes Awaiting changes and removed awaiting changes Awaiting changes awaiting change review Awaiting change review labels Jan 18, 2024
@lidavidm lidavidm requested a review from zeroshade January 19, 2024 15:22
Copy link
Copy Markdown
Member

@zeroshade zeroshade left a comment

Choose a reason for hiding this comment

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

LGTM

@github-actions github-actions bot added awaiting merge Awaiting merge and removed awaiting changes Awaiting changes labels Jan 19, 2024
@lidavidm lidavidm merged commit 143a7da into apache:main Jan 19, 2024
@lidavidm lidavidm removed the awaiting merge Awaiting merge label Jan 19, 2024
@lidavidm lidavidm deleted the gh39574 branch January 19, 2024 16:25
@conbench-apache-arrow
Copy link
Copy Markdown

After merging your PR, Conbench analyzed the 4 benchmarking runs that have been run so far on merge-commit 143a7da.

There were no benchmark performance regressions. 🎉

The full Conbench report has more details. It also includes information about 1 possible false positive for unstable benchmarks that are known to sometimes produce them.

lidavidm added a commit to apache/arrow-adbc that referenced this pull request Jan 22, 2024
soumyadsanyal pushed a commit to soumyadsanyal/arrow-adbc that referenced this pull request Jan 31, 2024
dgreiss pushed a commit to dgreiss/arrow that referenced this pull request Feb 19, 2024
### Rationale for this change

It's impossible to use the current bindings with PollFlightInfo. Required for apache/arrow-adbc#1457.

### What changes are included in this PR?

Add new methods that expose PollFlightInfo.

### Are these changes tested?

Yes

### Are there any user-facing changes?

Adds new methods.
* Closes: apache#39574

Authored-by: David Li <li.davidm96@gmail.com>
Signed-off-by: David Li <li.davidm96@gmail.com>
@raulcd
Copy link
Copy Markdown
Member

raulcd commented Apr 15, 2024

@github-actions crossbow submit verify-rc-source-integration-linux-*

@raulcd
Copy link
Copy Markdown
Member

raulcd commented Apr 15, 2024

I am verifying if this caused: #41201

@github-actions
Copy link
Copy Markdown

Revision: 2d89a1c

Submitted crossbow builds: ursacomputing/crossbow @ actions-c07bcbee39

Task Status
verify-rc-source-integration-linux-almalinux-8-amd64 GitHub Actions
verify-rc-source-integration-linux-conda-latest-amd64 GitHub Actions
verify-rc-source-integration-linux-ubuntu-20.04-amd64 GitHub Actions
verify-rc-source-integration-linux-ubuntu-22.04-amd64 GitHub Actions

lidavidm added a commit to adbc-drivers/snowflake that referenced this pull request Oct 9, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Go] Enable using PollFlightInfo in Flight SQL servers/clients

3 participants