lsst.dax.apdb.cassandra.cassandra_utils.SessionWrapper Class Reference

Public Member Functions
	__init__ (self, Session session, Any execution_profile=EXEC_PROFILE_DEFAULT)
Any	execute_async (self, *Any args, Any execution_profile=EXEC_PROFILE_DEFAULT, **Any kwargs)
Any	submit (self, *Any args, **Any kwargs)

Protected Attributes
	_session
	_execution_profile

Detailed Description

Special wrapper class to workaround ``execute_concurrent()`` issue
which does not allow non-default execution profile.

Instance of this class can be passed to execute_concurrent() instead
of `Session` instance. This class implements a small set of methods
that are needed by ``execute_concurrent()``. When
``execute_concurrent()`` is fixed to accept exectution profiles, this
wrapper can be dropped.

Definition at line 61 of file cassandra_utils.py.

Constructor & Destructor Documentation

__init__()

lsst.dax.apdb.cassandra.cassandra_utils.SessionWrapper.__init__	(		self,
		Session	session,
		Any	execution_profile = EXEC_PROFILE_DEFAULT )

Definition at line 72 of file cassandra_utils.py.

        def __init__(self, session: Session, execution_profile: Any = EXEC_PROFILE_DEFAULT):
            self._session = session
            self._execution_profile = execution_profile
 

Member Function Documentation

execute_async()

Any lsst.dax.apdb.cassandra.cassandra_utils.SessionWrapper.execute_async	(		self,
		*Any	args,
		Any	execution_profile = EXEC_PROFILE_DEFAULT,
		**Any	kwargs )

Definition at line 76 of file cassandra_utils.py.

        ) -> Any:
            # explicit parameter can override our settings
            if execution_profile is EXEC_PROFILE_DEFAULT:
                execution_profile = self._execution_profile
            return self._session.execute_async(*args, execution_profile=execution_profile, **kwargs)
 

submit()

Any lsst.dax.apdb.cassandra.cassandra_utils.SessionWrapper.submit	(		self,
		*Any	args,
		**Any	kwargs )

Definition at line 87 of file cassandra_utils.py.

        def submit(self, *args: Any, **kwargs: Any) -> Any:
            # internal method
            return self._session.submit(*args, **kwargs)
 
 

Member Data Documentation

_execution_profile

lsst.dax.apdb.cassandra.cassandra_utils.SessionWrapper._execution_profile

protected

Definition at line 74 of file cassandra_utils.py.

_session

lsst.dax.apdb.cassandra.cassandra_utils.SessionWrapper._session

protected

Definition at line 73 of file cassandra_utils.py.

---

The documentation for this class was generated from the following file:

• /j/snowflake/release/lsstsw/stack/lsst-scipipe-8.0.0/Linux64/dax_apdb/g88963caddf+0cb8e002cc/python/lsst/dax/apdb/cassandra/cassandra_utils.py