code: def retry(self, func, partition_id, retry_message, final_failure_message, max_retries, host_id):
          
          loop = asyncio.new_event_loop()
          loop.run_until_complete(self.retry_async(func, partition_id, retry_message,
                                                   final_failure_message, max_retries, host_id))
docs: Make attempt_renew_lease async call sync.