async def METHOD_NAME(self):
    self.client = WorkerClient()
    print("Connecting to {}".format(self._server_url))
    try:
        await self.client.connect_url(self._server_url)
    except KeyboardInterrupt:
        raise
    except Exception:
        traceback.print_exception(*sys.exc_info())