129
132
_transport_store = threading.local()
131
134
def get_transport_for_thread(base):
133
135
thread_transports = getattr(_transport_store, 'transports', None)
134
136
if thread_transports is None:
135
137
thread_transports = _transport_store.transports = {}