errori di cattura in asyncio.ensure_future

Question

ho questo codice:

try: 
    asyncio.ensure_future(data_streamer.sendByLatest()) 
except ValueError as e: 
    logging.debug(repr(e)) 

data_streamer.sendByLatest() può sollevare un ValueError, ma non è catturato.

Answer 1

ensure_future - crea solo Task e torna immediatamente. Si dovrebbe attendere per attività creata per farlo è risultato (compreso caso quando si solleva eccezione):

import asyncio 


async def test(): 
    await asyncio.sleep(0) 
    raise ValueError('123') 


async def main():  
    try: 
     task = asyncio.ensure_future(test()) # Task aren't finished here yet 
     await task # Here we await for task finished and here exception would be raised 
    except ValueError as e: 
     print(repr(e)) 


if __name__ == '__main__': 
    loop = asyncio.get_event_loop() 
    loop.run_until_complete(main()) 

uscita:

ValueError('123',) 

Nel caso in cui non si ha intenzione di attendere immediatamente compito dopo averlo creato , si potrebbe attendere in un secondo momento (per sapere come è finita):

async def main():  
    task = asyncio.ensure_future(test()) 
    await asyncio.sleep(1) 
    # At this moment task finished with exception, 
    # but we didn't retrieved it's exception. 
    # We can do it just awaiting task: 
    try: 
     await task 
    except ValueError as e: 
     print(repr(e)) 

uscita è lo stesso:

ValueError('123',)