Skip to content

fix: snowpipe streaming poll re-create channel in case of invalid#6711

Merged
achettyiitr merged 3 commits intomasterfrom
fix.snowpipe-streaming-poll-recreate
Feb 24, 2026
Merged

fix: snowpipe streaming poll re-create channel in case of invalid#6711
achettyiitr merged 3 commits intomasterfrom
fix.snowpipe-streaming-poll-recreate

Conversation

@achettyiitr
Copy link
Member

@achettyiitr achettyiitr commented Feb 23, 2026

🔒 Scanned for secrets using gitleaks 8.29.1

Description

  • In case of an invalid channel, re-create the channel and get the status API.

Linear Ticket

  • Resolves INT-5918

Security

  • The code changed/added as part of this pull request won't create any security issues with how the software is being used.

@achettyiitr
fix: snowpipe streaming poll re-create channel in case of invalid
0e1fa21 
🔒 Scanned for secrets using gitleaks 8.29.1
@codecov
Copy link

codecov bot commented Feb 23, 2026 •
edited
Loading

Codecov Report

❌ Patch coverage is 83.33333% with 6 lines in your changes missing coverage. Please review.
✅ Project coverage is 79.74%. Comparing base (8dd73ad) to head (13f51bb).
⚠️ Report is 2 commits behind head on master.

Files with missing lines Patch % Lines
...tionmanager/snowpipestreaming/snowpipestreaming.go 83.33% 3 Missing and 3 partials ⚠️
Additional details and impacted files 
@@            Coverage Diff             @@
##           master    #6711      +/-   ##
==========================================
+ Coverage   79.71%   79.74%   +0.02%     
==========================================
  Files         566      566              
  Lines       63341    63368      +27     
==========================================
+ Hits        50494    50531      +37     
+ Misses       9867     9849      -18     
- Partials     2980     2988       +8

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

@achettyiitr
chore: review comments
b679092 
🔒 Scanned for secrets using gitleaks 8.29.1
@achettyiitr achettyiitr force-pushed the fix.snowpipe-streaming-poll-recreate branch from a5ec363 to b679092 Compare February 24, 2026 04:55
@achettyiitr
Merge branch 'master' into fix.snowpipe-streaming-poll-recreate
13f51bb 
🔒 Scanned for secrets using gitleaks 8.29.1
@achettyiitr achettyiitr force-pushed the fix.snowpipe-streaming-poll-recreate branch from 7cbc071 to 13f51bb Compare February 24, 2026 10:54
@achettyiitr achettyiitr merged commit e379c1f into master Feb 24, 2026
68 checks passed
@achettyiitr achettyiitr deleted the fix.snowpipe-streaming-poll-recreate branch February 24, 2026 11:25
This was referenced Mar 2, 2026
Closed
Merged
mihir20 pushed a commit that referenced this pull request Mar 2, 2026
@rudderstack-github-actions
chore: prerelease 1.69.0-rc.1 (#6729)
7eafb38 
🤖 I have created a release *beep* *boop*
---


##
[1.69.0-rc.1](v1.68.0...v1.69.0-rc.1)
(2026-03-02)


### Bug Fixes

* application context for async jobs framework
([#6709](#6709))
([8dd73ad](8dd73ad))
* **batchrouter:** klaviyo bulk upload manager tries to update
zero-valued job ids in case of failures causing panics
([#6701](#6701))
([67befa5](67befa5))
* false sanity check failures
([#6713](#6713))
([ec12382](ec12382))
* snowpipe streaming delete channel logs
([#6695](#6695))
([8998ece](8998ece))
* snowpipe streaming poll re-create channel in case of invalid
([#6711](#6711))
([e379c1f](e379c1f))
* snowpipe streaming recreate channel error response
([#6717](#6717))
([bceafef](bceafef))


### Miscellaneous

* add backwards compatibility tests for getCredential
([#6719](#6719))
([32dbe77](32dbe77))
* add more test cases for pytransformer contract backwards compatibility
([#6698](#6698))
([9b59ab3](9b59ab3))
* additional logs for async framework
([#6708](#6708))
([c16c885](c16c885))
* **gateway:** acknowledge reload requests in a transaction
([#6706](#6706))
([ef467b1](ef467b1))
* **jobsdb:** optimize partition id read exclusion filter
([#6724](#6724))
([936b9aa](936b9aa))
* move oauth destination logic to backend-config package
([#6677](#6677))
([4d194a3](4d194a3))
* pytransformer contract testing
([#6672](#6672))
([395a4fb](395a4fb))
* replace goimports with gci
([#6722](#6722))
([5947894](5947894))
* snowpipe streaming duplicate events due to offset
([#6712](#6712))
([db6b404](db6b404))
* sync release v1.68.0 to main branch
([#6696](#6696))
([2785583](2785583))
* use release name as etcd namespace
([#6707](#6707))
([fbf0892](fbf0892))

---
This PR was generated with [Release
Please](https://github.com/googleapis/release-please). See
[documentation](https://github.com/googleapis/release-please#release-please).

Co-authored-by: rudderstack-github-actions[bot] <236995729+rudderstack-github-actions[bot]@users.noreply.github.com>
This was referenced Mar 3, 2026
Merged
Merged
mihir20 pushed a commit that referenced this pull request Mar 3, 2026
@rudderstack-github-actions
chore: prerelease 1.69.0-rc.1 (#6732)
325a26f 
🤖 I have created a release *beep* *boop*
---


##
[1.69.0-rc.1](v1.68.0...v1.69.0-rc.1)
(2026-03-03)


### Bug Fixes

* application context for async jobs framework
([#6709](#6709))
([8dd73ad](8dd73ad))
* **batchrouter:** klaviyo bulk upload manager tries to update
zero-valued job ids in case of failures causing panics
([#6701](#6701))
([67befa5](67befa5))
* false sanity check failures
([#6713](#6713))
([ec12382](ec12382))
* snowpipe streaming delete channel logs
([#6695](#6695))
([8998ece](8998ece))
* snowpipe streaming poll re-create channel in case of invalid
([#6711](#6711))
([e379c1f](e379c1f))
* snowpipe streaming recreate channel error response
([#6717](#6717))
([bceafef](bceafef))


### Miscellaneous

* add backwards compatibility tests for getCredential
([#6719](#6719))
([32dbe77](32dbe77))
* add geolocation backwards compatibility test
([#6720](#6720))
([c03af7d](c03af7d))
* add more test cases for pytransformer contract backwards compatibility
([#6698](#6698))
([9b59ab3](9b59ab3))
* additional logs for async framework
([#6708](#6708))
([c16c885](c16c885))
* force release 1.69.0
([#6730](#6730))
([2390bfb](2390bfb))
* **gateway:** acknowledge reload requests in a transaction
([#6706](#6706))
([ef467b1](ef467b1))
* **jobsdb:** optimize partition id read exclusion filter
([#6724](#6724))
([936b9aa](936b9aa))
* move oauth destination logic to backend-config package
([#6677](#6677))
([4d194a3](4d194a3))
* pytransformer contract testing
([#6672](#6672))
([395a4fb](395a4fb))
* replace goimports with gci
([#6722](#6722))
([5947894](5947894))
* snowpipe streaming duplicate events due to offset
([#6712](#6712))
([db6b404](db6b404))
* sync release v1.68.0 to main branch
([#6696](#6696))
([2785583](2785583))
* use release name as etcd namespace
([#6707](#6707))
([fbf0892](fbf0892))

---
This PR was generated with [Release
Please](https://github.com/googleapis/release-please). See
[documentation](https://github.com/googleapis/release-please#release-please).

Co-authored-by: rudderstack-github-actions[bot] <236995729+rudderstack-github-actions[bot]@users.noreply.github.com>
@rudderstack-github-actions rudderstack-github-actions bot mentioned this pull request Mar 3, 2026
Merged
mihir20 pushed a commit that referenced this pull request Mar 3, 2026
@rudderstack-github-actions
chore: prerelease 1.69.0-rc.1 (#6735)
b51c190 
🤖 I have created a release *beep* *boop*
---


##
[1.69.0-rc.1](v1.68.0...v1.69.0-rc.1)
(2026-03-03)


### Bug Fixes

* application context for async jobs framework
([#6709](#6709))
([8dd73ad](8dd73ad))
* **batchrouter:** klaviyo bulk upload manager tries to update
zero-valued job ids in case of failures causing panics
([#6701](#6701))
([67befa5](67befa5))
* false sanity check failures
([#6713](#6713))
([ec12382](ec12382))
* snowpipe streaming delete channel logs
([#6695](#6695))
([8998ece](8998ece))
* snowpipe streaming poll re-create channel in case of invalid
([#6711](#6711))
([e379c1f](e379c1f))
* snowpipe streaming recreate channel error response
([#6717](#6717))
([bceafef](bceafef))


### Miscellaneous

* add backwards compatibility tests for getCredential
([#6719](#6719))
([32dbe77](32dbe77))
* add geolocation backwards compatibility test
([#6720](#6720))
([c03af7d](c03af7d))
* add more test cases for pytransformer contract backwards compatibility
([#6698](#6698))
([9b59ab3](9b59ab3))
* additional logs for async framework
([#6708](#6708))
([c16c885](c16c885))
* force release 1.69.0
([#6730](#6730))
([2390bfb](2390bfb))
* **gateway:** acknowledge reload requests in a transaction
([#6706](#6706))
([ef467b1](ef467b1))
* **jobsdb:** optimize partition id read exclusion filter
([#6724](#6724))
([936b9aa](936b9aa))
* move oauth destination logic to backend-config package
([#6677](#6677))
([4d194a3](4d194a3))
* pytransformer contract testing
([#6672](#6672))
([395a4fb](395a4fb))
* replace goimports with gci
([#6722](#6722))
([5947894](5947894))
* snowpipe streaming duplicate events due to offset
([#6712](#6712))
([db6b404](db6b404))
* sync release v1.68.0 to main branch
([#6696](#6696))
([2785583](2785583))
* use release name as etcd namespace
([#6707](#6707))
([fbf0892](fbf0892))

---
This PR was generated with [Release
Please](https://github.com/googleapis/release-please). See
[documentation](https://github.com/googleapis/release-please#release-please).

Co-authored-by: rudderstack-github-actions[bot] <236995729+rudderstack-github-actions[bot]@users.noreply.github.com>
mihir20 pushed a commit that referenced this pull request Mar 4, 2026
@rudderstack-github-actions
chore: release 1.69.0 (#6731)
046e767 
🤖 I have created a release *beep* *boop*
---


##
[1.69.0](v1.68.0...v1.69.0)
(2026-03-03)


### Bug Fixes

* application context for async jobs framework
([#6709](#6709))
([8dd73ad](8dd73ad))
* **batchrouter:** klaviyo bulk upload manager tries to update
zero-valued job ids in case of failures causing panics
([#6701](#6701))
([67befa5](67befa5))
* false sanity check failures
([#6713](#6713))
([ec12382](ec12382))
* snowpipe streaming delete channel logs
([#6695](#6695))
([8998ece](8998ece))
* snowpipe streaming poll re-create channel in case of invalid
([#6711](#6711))
([e379c1f](e379c1f))
* snowpipe streaming recreate channel error response
([#6717](#6717))
([bceafef](bceafef))


### Miscellaneous

* add backwards compatibility tests for getCredential
([#6719](#6719))
([32dbe77](32dbe77))
* add geolocation backwards compatibility test
([#6720](#6720))
([c03af7d](c03af7d))
* add more test cases for pytransformer contract backwards compatibility
([#6698](#6698))
([9b59ab3](9b59ab3))
* additional logs for async framework
([#6708](#6708))
([c16c885](c16c885))
* force release 1.69.0
([#6730](#6730))
([2390bfb](2390bfb))
* **gateway:** acknowledge reload requests in a transaction
([#6706](#6706))
([ef467b1](ef467b1))
* **jobsdb:** optimize partition id read exclusion filter
([#6724](#6724))
([936b9aa](936b9aa))
* move oauth destination logic to backend-config package
([#6677](#6677))
([4d194a3](4d194a3))
* pytransformer contract testing
([#6672](#6672))
([395a4fb](395a4fb))
* replace goimports with gci
([#6722](#6722))
([5947894](5947894))
* snowpipe streaming duplicate events due to offset
([#6712](#6712))
([db6b404](db6b404))
* sync release v1.68.0 to main branch
([#6696](#6696))
([2785583](2785583))
* use release name as etcd namespace
([#6707](#6707))
([fbf0892](fbf0892))

---
This PR was generated with [Release
Please](https://github.com/googleapis/release-please). See
[documentation](https://github.com/googleapis/release-please#release-please).

Co-authored-by: rudderstack-github-actions[bot] <236995729+rudderstack-github-actions[bot]@users.noreply.github.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

@krishna2020 krishna2020 krishna2020 approved these changes

@shekhar-rudder shekhar-rudder shekhar-rudder approved these changes

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

3 participants

@achettyiitr @krishna2020 @shekhar-rudder