code: def work(self):
          
          try:
              raise self._error
          except TypeError:
              pass
          except Exception as e:
              _logger.warning("%r", e)
              raise
          try:
              self.lock()
              self._conn.do_work()
          except compat.TimeoutException:
              _logger.debug("Connection %r timed out while waiting for lock acquisition.", self.container_id)
          finally:
              self.release()
docs: Perform a single Connection iteration.