@utils.positional(<NUM_LIT:2>)<EOL><INDENT>def map_async(self, callback, pass_batch_into_callback=None,<EOL>merge_future=None, **q_options):<DEDENT>
qry = self._fix_namespace()<EOL>return tasklets.get_context().map_query(<EOL>qry,<EOL>callback,<EOL>pass_batch_into_callback=pass_batch_into_callback,<EOL>options=self._make_options(q_options),<EOL>merge_future=merge_future)<EOL>
Map a callback function or tasklet over the query results.

        This is the asynchronous version of Query.map().