Repository navigation
Commit 0de9196
feat(cassandra): Add multi-DC support via per-datacenter execution profiles (feast-dev#6434)
* feat(cassandra): add multi-DC support via per-datacenter execution profiles
Introduce a `datacenters` config list as an alternative to the flat
`hosts` field. Each entry specifies the contact points, local_dc, and
optional replication metadata for one datacenter.
On connect, a named Cassandra execution profile is registered per DC
(profile key = local_dc), enabling callers to route driver-level queries
to a specific datacenter. The default profile is pinned to
`load_balancing.local_dc`, or the first DC when load_balancing is absent.
All existing `hosts` / `secure_bundle_path` configs are fully backward
compatible — the original code path is untouched.
Also updates docs/reference/online-stores/cassandra.md with a multi-DC
feature_store.yaml example.
Signed-off-by: singhhimanshu0811
email : itssinghhimanshu@gmail.com
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* implemented suggestions and tests
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* doc -s
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* doc -s
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* empty commit
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* trigger build
Signed-off-by: Himanshu Singh <itssinghhimanshu@gmail.com>
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* secrets whitelisting
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* fix: apply ruff format and fix pre-commit secret/linting issues
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* fix: bump cassandra-driver minimum to 3.26.0 for execution_profile support in execute_concurrent_with_args
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* fix: add type annotations to resolve mypy errors in Branch A cluster_kwargs
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* fix: rename Branch A execution_profiles variable to avoid mypy no-redef error
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* fix: rename Branch A cluster_kwargs to avoid mypy no-redef with Branch B
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* fix: rename Branch A cluster_kwargs to avoid mypy no-redef with Branch B
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* regenerated pixi
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
* trigger build
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
---------
Signed-off-by: singhhimanshu0811
Signed-off-by: Himanshu Singh <himanshu.singh@walmart.com>
Co-authored-by: Himanshu Singh <himanshu.singh@walmart.com>1 parent de11152 commit 0de9196
5 files changed
Lines changed: 1606 additions & 705 deletions
File tree
- docs/reference/online-stores
- sdk/python
- feast/infra/online_stores/cassandra_online_store
- tests/unit/infra/online_store
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
37 | 37 | | |
38 | 38 | | |
39 | 39 | | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
40 | 85 | | |
41 | 86 | | |
42 | 87 | | |
| |||
0 commit comments