def METHOD_NAME(self, job):
    """
    Schedules a job to run asynchronously in the XRPL worker thread.
    The job should be a Future (for example, from calling an async function)
    """
    task = asyncio.run_coroutine_threadsafe(job, self.worker.loop)