'Worker threads may not share the same connection'

def get_connection(self):

    thread = threading.current_thread()
    ident = thread.ident
    service = self._service_pool.get(ident)
    if (service is None):
        credentials = self.credentials_manager.get_credentials()
        http_client = self._HTTPClass()
        credentials.authorize(http_client)
        service = apiclient.discovery.build('storage', 'v1', http=http_client)
        self._service_pool[ident] = service
    return service
