[ENH] V1 -> V2 Migration - Flows (module)#1609
Conversation
Codecov Report❌ Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## main #1609 +/- ##
==========================================
- Coverage 54.64% 54.53% -0.11%
==========================================
Files 63 63
Lines 5124 5169 +45
==========================================
+ Hits 2800 2819 +19
- Misses 2324 2350 +26 ☔ View full report in Codecov by Sentry. 🚀 New features to boost your workflow:
|
614411f to
36184e5
Compare
|
Hi @geetu040 !! Can you review the pre-commit failure It was due to merge conflicts more specifically for tasks . Should I change it on my branch ? |
can you try again, sync your branch with mine? It should be fixed now. |
|
I think that due to conflicts it did not synced properly . I have to revert it manually |
geetu040
left a comment
There was a problem hiding this comment.
Nice overall, few changes needed. I'll look at the tests later when the implementation is final.
…into flow-migration-stacked
…into flow-migration-stacked
Signed-off-by: Omswastik-11 <omswastikpanda11@gmail.com>
Signed-off-by: Omswastik-11 <omswastikpanda11@gmail.com>
Signed-off-by: Omswastik-11 <omswastikpanda11@gmail.com>
…into flow-migration-stacked
Signed-off-by: Omswastik-11 <omswastikpanda11@gmail.com>
geetu040
left a comment
There was a problem hiding this comment.
sdk code look good so far, please take a look at #1575 (comment) and make changes accordingly where needed.
all tests (existing and new) should pass to make sure we are retaining the original functionality of the sdk
| assert subflow.flow_id == sub_flow_id | ||
|
|
||
| @pytest.mark.test_server() | ||
| def test_tagging(self): |
There was a problem hiding this comment.
this test in theory should work as before, if it's passing in main, it should pass here as well.
There was a problem hiding this comment.
The migrated FlowV1API.list() uses HTTP caching (enable_cache=True). After push_tag → list_flows(tag=tag) returns 1 result and caches it. After remove_tag, the next list_flows(tag=tag) returns the stale cached result (1 instead of 0). The old code path didn't cache flow listings.
Co-authored-by: Armaghan Shakir <raoarmaghanshakir040@gmail.com>
Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>
| @pytest.mark.test_server() | ||
| def test_flow_v1_get(flow_v1): | ||
| flow = flow_v1.get(flow_id=1) | ||
| _validate_flow(flow) |
| @pytest.mark.test_server() | ||
| def test_flow_v2_get(flow_v2): | ||
| flow = flow_v2.get(flow_id=1) | ||
| _validate_flow(flow) |
Co-authored-by: Armaghan Shakir <raoarmaghanshakir040@gmail.com>
Co-authored-by: Armaghan Shakir <raoarmaghanshakir040@gmail.com>
geetu040
left a comment
There was a problem hiding this comment.
Nice work @Omswastik-11.
@PGijsbers please review/merge.
Fixes #1601
added a
Createmethod inFlowAPIfor publishing flow but not refactored with oldpublish. (Needs discussion on this)Added tests using
fake_methodsso that we can test without localV2server . I have tested theFlowsV2methods (getandexists) anddeleteandlistwere not implemented inV2server so I skipped them .