From aebdf9444b3a180c62ff221e6c81fb776b24da91 Mon Sep 17 00:00:00 2001 From: cybermaggedon Date: Wed, 10 Dec 2025 10:55:14 +0000 Subject: [PATCH] Fix incorrect Cassandra config invocation (#587) --- trustgraph-flow/trustgraph/query/objects/cassandra/service.py | 2 +- trustgraph-flow/trustgraph/storage/rows/cassandra/write.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/trustgraph-flow/trustgraph/query/objects/cassandra/service.py b/trustgraph-flow/trustgraph/query/objects/cassandra/service.py index a4726d90..a6683c40 100644 --- a/trustgraph-flow/trustgraph/query/objects/cassandra/service.py +++ b/trustgraph-flow/trustgraph/query/objects/cassandra/service.py @@ -74,7 +74,7 @@ class Processor(FlowProcessor): cassandra_password = params.get("cassandra_password") # Resolve configuration with environment variable fallback - hosts, username, password = resolve_cassandra_config( + hosts, username, password, keyspace = resolve_cassandra_config( host=cassandra_host, username=cassandra_username, password=cassandra_password diff --git a/trustgraph-flow/trustgraph/storage/rows/cassandra/write.py b/trustgraph-flow/trustgraph/storage/rows/cassandra/write.py index ef79e605..1576b70c 100755 --- a/trustgraph-flow/trustgraph/storage/rows/cassandra/write.py +++ b/trustgraph-flow/trustgraph/storage/rows/cassandra/write.py @@ -42,7 +42,7 @@ class Processor(Consumer): cassandra_password = params.get("cassandra_password") # Resolve configuration with environment variable fallback - hosts, username, password = resolve_cassandra_config( + hosts, username, password, keyspace = resolve_cassandra_config( host=cassandra_host, username=cassandra_username, password=cassandra_password