You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I'm trying to implement a disk KV store into my already existing and working pipeline with an SQLStore, to speed up response times.
The Readme states to use settings.pipeline.expire to manually expire the KV, as it's not expiring automatically.
I'm not 100% certain what this is supposed to mean, as this method does not exist, but I assumed cass.configuration.settings.expire_sinks() is meant. As I only want to expire the KV store, I tried to manually expire it:
""" Cass has been initialized with both datastores and some more stuff, like expirations """forsinkincass.configuration.settings.pipeline._sinks:
ifisinstance(sink, cassiopeia_diskstore.SimpleKVDiskStore):
print("Expiring cass KV sink.")
sink.expire()
I'm trying to implement a disk KV store into my already existing and working pipeline with an SQLStore, to speed up response times.
The Readme states to use
settings.pipeline.expire
to manually expire the KV, as it's not expiring automatically.I'm not 100% certain what this is supposed to mean, as this method does not exist, but I assumed
cass.configuration.settings.expire_sinks()
is meant. As I only want to expire the KV store, I tried to manually expire it:But I get an error:
The error seems to be here:
cassiopeia-datastores/cassiopeia-diskstore/cassiopeia_diskstore/__init__.py
Line 62 in 2fd4d68
Am I doing something wrong? What would be the best practice?
and/or
Is my assumption of this bug correct?
The text was updated successfully, but these errors were encountered: