Skip to content
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

Expose Parallel Fetch #787

Merged
merged 15 commits into from
Aug 12, 2021
Merged

Expose Parallel Fetch #787

merged 15 commits into from
Aug 12, 2021

Conversation

sfc-gh-kzaveri
Copy link
Contributor

@sfc-gh-kzaveri sfc-gh-kzaveri commented Jul 2, 2021

This PR merges all parallel-fetch-prpr branch changes in to master.

sfc-gh-kzaveri and others added 13 commits August 11, 2021 21:12
…nd `result_batch` (#733)

* Revert "Revert "SNOW-296993 reworking internals for result_set and result_chunks (#688)""

This reverts commit c5c31fa.

* Refactor resultset/batch, add to_arrow/pandas, add tests

* Address comments
…s` (#735)

* Revert "Revert "SNOW-296993 reworking internals for result_set and result_chunks (#688)""

This reverts commit c5c31fa.

* Add schema to ResultBatch and add test

* Update type hints

* Use ResultMetadata named tuple in tests

* Update formatting

* Address comments, remove column_names

* Keep column_converters, make code a little more readable

* Address comments, add docstring

* Add property for column_names

* Fix rebase issues
* Add test_empty case for arrow

* Simplify value string

* Fetch arrow all test

* Add fetch_arrow_batches test
* Rewrite result_set iterator

* Fix rebase issue

* Update test

* Change logging to use f strings, update fetch behaviour
* Add proper retry and error handling

* Changed to raise encapsulated request

* Fix failing test

* Update tests, add f-strings

* Add retries to test
* Add using sessions functionality

* Add tests

* remove arrow from test

* Address comments
* Replace generators with iterators

* Make _parse return a list

* Fix olddriver tests

* Update _parse and cursor iterating logic

* Update test to check iter function

* Add type hints and result batch id

* Make id an attribute
* Fix prpr tests

* Fix error msg formatting
@codecov-commenter
Copy link

codecov-commenter commented Aug 12, 2021

Codecov Report

Merging #787 (ff074b7) into master (0130a50) will decrease coverage by 0.16%.
The diff coverage is 94.07%.

Impacted file tree graph

@@            Coverage Diff             @@
##           master     #787      +/-   ##
==========================================
- Coverage   82.79%   82.63%   -0.17%     
==========================================
  Files          58       58              
  Lines        7481     7680     +199     
  Branches     1127     1164      +37     
==========================================
+ Hits         6194     6346     +152     
- Misses        967     1011      +44     
- Partials      320      323       +3     
Impacted Files Coverage Δ
src/snowflake/connector/errorcode.py 100.00% <ø> (ø)
src/snowflake/connector/errors.py 89.94% <77.27%> (-0.80%) ⬇️
src/snowflake/connector/time_util.py 83.72% <86.66%> (+0.96%) ⬆️
src/snowflake/connector/cursor.py 93.36% <91.76%> (-1.29%) ⬇️
src/snowflake/connector/result_batch.py 93.72% <93.72%> (ø)
src/snowflake/connector/arrow_context.py 82.05% <100.00%> (+0.23%) ⬆️
src/snowflake/connector/connection.py 92.62% <100.00%> (-0.16%) ⬇️
src/snowflake/connector/constants.py 96.49% <100.00%> (+0.12%) ⬆️
src/snowflake/connector/converter.py 89.62% <100.00%> (+0.56%) ⬆️
src/snowflake/connector/network.py 81.85% <100.00%> (+0.77%) ⬆️
... and 15 more

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 0130a50...ff074b7. Read the comment docs.

Copy link
Collaborator

@sfc-gh-mkeller sfc-gh-mkeller left a comment

Choose a reason for hiding this comment

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

Already reviewed in pieces! 🚢 🚢

@jonashaag
Copy link

sfc-gh-aling pushed a commit that referenced this pull request Oct 17, 2022
* Revert "Revert "SNOW-296993 reworking internals for result_set and result_chunks (#688)""

This reverts commit 7401783.

* Revert "Revert "SNOW-296993 fixing import statement for SnowSQL (#697)""

This reverts commit 4b7d612.

* Revert "Revert "SNOW-296993 fixing a ResultBatch telemetry bug (#701)""

This reverts commit 6bab3dc.

* Revert "Revert "SNOW-336959 Add telemetry for pandas fetch functions (#699)""

This reverts commit 03a2f85.

* SNOW-177082 Adds `to_arrow` and `to_pandas`, refactors `result_set` and `result_batch` (#733)

* Revert "Revert "SNOW-296993 reworking internals for result_set and result_chunks (#688)""

This reverts commit 7401783.

* Refactor resultset/batch, add to_arrow/pandas, add tests

* Address comments

* SNOW-361357 Provide interface exposing `schema` info to `ResultBatches` (#735)

* Revert "Revert "SNOW-296993 reworking internals for result_set and result_chunks (#688)""

This reverts commit 7401783.

* Add schema to ResultBatch and add test

* Update type hints

* Use ResultMetadata named tuple in tests

* Update formatting

* Address comments, remove column_names

* Keep column_converters, make code a little more readable

* Address comments, add docstring

* Add property for column_names

* Fix rebase issues

* SNOW-370785 Add Fetch Arrow Tests (#766)

* Add test_empty case for arrow

* Simplify value string

* Fetch arrow all test

* Add fetch_arrow_batches test

* SNOW-361211 Adds Updated Fetching Logic (#775)

* Rewrite result_set iterator

* Fix rebase issue

* Update test

* Change logging to use f strings, update fetch behaviour

* SNOW-361210 Adds Retry Logic and Tests (#780)

* Add proper retry and error handling

* Changed to raise encapsulated request

* Fix failing test

* Update tests, add f-strings

* Add retries to test

* SNOW-361211 Allow ResultBatches to use existing Sessions (#790)

* Add using sessions functionality

* Add tests

* remove arrow from test

* Address comments

* SNOW-414845 Fix Pandas and JSON Parallel Fetch (#811)

* Replace generators with iterators

* Make _parse return a list

* Fix olddriver tests

* Update _parse and cursor iterating logic

* Update test to check iter function

* Add type hints and result batch id

* Make id an attribute

* reverting a behavior change before it happens and adding tests that will keep verifying behaviors

* SNOW-421184 Parallel Fetch Clean Up (#821)

* Misc: Fix prpr tests, error msg formatting, mark a new test skipolddriver, update logging

Co-authored-by: Mark Keller <mark.keller@snowflake.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

4 participants