Глядя на реализацию , кажется, Query.map_async
- это просто ярлык для вызова Context.map_query
:
def map_async(self, callback, merge_future=None, **q_options):
"""Map a callback function or tasklet over the query results.
This is the asynchronous version of Query.map().
"""
return tasklets.get_context().map_query(self, callback,
options=_make_options(q_options),
merge_future=merge_future)