backends.cassandra

Apache Cassandra result store backend using the DataStax driver.

Module Contents

Classes

CassandraBackend(self,servers=None,keyspace=None,table=None,entry_ttl=None,port=9042,**kwargs) Cassandra backend utilizing DataStax driver.

Functions

buf_t(x)
buf_t(x)
class CassandraBackend(servers=None, keyspace=None, table=None, entry_ttl=None, port=9042, **kwargs)

Cassandra backend utilizing DataStax driver.

Raises:
celery.exceptions.ImproperlyConfigured:
if module :pypi:`cassandra-driver` is not available, or if the :setting:`cassandra_servers` setting is not set.
__init__(servers=None, keyspace=None, table=None, entry_ttl=None, port=9042, **kwargs)
process_cleanup()
_get_connection(write=False)

Prepare the connection for action.

Arguments:
write (bool): are we a writer?
_store_result(task_id, result, state, traceback=None, request=None, **kwargs)

Store return value and state of an executed task.

as_uri(include_password=True)
_get_task_meta_for(task_id)

Get task meta-data for a task by id.

__reduce__(args=tuple, kwargs=dict)