This is how I patched the SwiftService for the time being:
class SwiftConnectionService(SwiftService): def __init__(self, connection, options=None): """ Override the manager before it's used """ SwiftService.__init__(self, options=options) def create_connection(): return connection # clean up the resources self.thread_manager.__exit__(None, None, None) self.thread_manager = MultiThreadingManager( create_connection, segment_threads=self._options['segment_threads'], object_dd_threads=self._options['object_dd_threads'], object_uu_threads=self._options['object_uu_threads'], container_threads=self._options['container_threads'] )
This is how I patched the SwiftService for the time being:
class SwiftConnection Service( SwiftService) :
SwiftService. __init_ _(self, options=options) connection( ):
self.thread_ manager. __exit_ _(None, None, None)
self.thread_ manager = MultiThreadingM anager(
create_ connection,
segment_ threads= self._options[ 'segment_ threads' ],
object_ dd_threads= self._options[ 'object_ dd_threads' ],
object_ uu_threads= self._options[ 'object_ uu_threads' ],
container_ threads= self._options[ 'container_ threads' ]
def __init__(self, connection, options=None):
"""
Override the manager before it's used
"""
def create_
return connection
# clean up the resources
)