As shown below, I am processing websocket data using asyncio with django's custom command.
The original source code is extremely long, so I have omitted it.

When I followed it in debugging, I was able to get back to method3, but it stopped at return out_layer of method2.
Can anyone give me some advice?

(When using asyncio, the error message cannot be displayed and it is difficult to determine why it is stopped.)

What I want to do is start receiving method2 and a new message at the same time after save_data is done.

class Command (BaseCommand):
    def handle (self, * args, ** kwargs):
            "" "Start loop" ""
            loop = asyncio.get_event_loop ()
            loop.create_task (self.stream ())
            print ('start receiving')
            try: try:
                loop.run_forever ()
            except KeyboardInterrupt:
                exit ()
    async def stream (self):
        uri ='ws: // localhost: 1234 /'
        async with websockets.connect (uri, ping_interval = None) as ws:
            while not ws.closed:
                response = await ws.recv ()
                content = json.loads (response)
                task = loop.create_task (self.save_pushdata (content, sid))
                task.add_done_callback (self.finish)
    async def save_pushdata (self, content, sid):
        loop = asyncio.get_event_loop ()
        newData = list (
            symbol = content ['****'],
        )
        newData.save ()
        task = loop.create_task (self.method2 (content, sid))
        task.add_done_callback (self.finish)
        save_pushdata_sid = str (sid) +'save_pushdata'
        return save_pushdata_sid
    async def method2 (self, content):
        args1 = self.method4 (content)
        args2 = self.method5 (content)
        self.method3 (args1, args2)
        method2_sid = str (sid) +'method2'
        return method2_sid
    def method3 (self, content):
        print ('123')
        return content
    def method4 (self, content):
        newData = list (
            symbol = content ['****'],
        )
        newData.save ()
        return content ['****']
    def method5 (self, content):
        newData = list (
            symbol = content ['****'],
        )
        newData.save ()
        return content ['****']
    def finish (self, text):
        logging.info ('% s', text.result ())

  def handle (self, * args, ** kwargs):
            "" "Start loop" ""
            loop = asyncio.get_event_loop ()
            loop.create_task (self.stream ())
            print ('start receiving')
            try: try:
                loop.run_forever ()
            except KeyboardInterrupt:
                exit ()
    async def stream (self):
        uri ='ws: // localhost: 1234 /'
        async with websockets.connect (uri, ping_interval = None) as ws:
            while not ws.closed:
                response = await ws.recv ()
                content = json.loads (response)
                executor = concurrent.futures.ProcessPoolExecutor ()
                queue = asyncio.Queue ()
                for i in range (10):
                    queue.put_nowait (i)
                async def proc (q):
                    while not q.empty ():
                        i = await q.get ()
                        future = loop.run_in_executor (executor, save_pushdata (content, sid), i)
                        await future
                tasks = [proc (queue) for i in range (4)] # 4 = number of cpu core
                return await asyncio.wait (tasks)
def save_pushdata (self, content, sid):
        loop = asyncio.get_event_loop ()
        newData = list (
            symbol = content ['****'],
        )
        newData.save ()
        self.method2 (content, sid)