Method create_task

packages/opal-common/opal_common/utils.py:253–268

Creates a task on the thread's asyncio loop *without* waiting for it to finish. This is intended to be called from the parent thread as a set-and-forget. the scheduled coroutine is put on the thread's queue and is consumed by one of the thread workers.

(self, coro: Coroutine)

        self.loop.stop()

    def create_task(self, coro: Coroutine):
        """Creates a task on the thread's asyncio loop *without* waiting for it
        to finish. This is intended to be called from the parent thread as a
        set-and-forget.

        the scheduled coroutine is put on the thread's queue and is
        consumed by one of the thread workers.
        """

        async def _schedule_task():
            """Since the queue is infinite, queue.put() will not block."""
            await self._queue.put(coro)

        # the asyncio loop might not be running yet (if the thread was
        # not yet started), therefore we do not block on the result.
        return asyncio.run_coroutine_threadsafe(_schedule_task(), loop=self.loop)

    def run_coro(self, coro: Coroutine):
        """Can be called from the main thread, but will run the coroutine on