google.appengine.ext.ndb.ReducingFuture

A Queue following the same protocol as MultiFuture.

Inherits From: Future, expected_type

google.appengine.ext.ndb.ReducingFuture(
    reducer, info=None, batch_size=20
)

However the result, instead of being a list of results of dependent Futures, is computed by calling a 'reducer' tasklet. The reducer tasklet takes a list of values and returns a single value. It may be called multiple times on sublists of values and should behave like e.g. sum().

NOTE: The reducer input values may be reordered compared to the order in which they were added to the queue.

state

Methods

add_callback

View source

add_callback(
    callback, *args, **kwds
)

add_dependent

View source

add_dependent(
    fut
)

add_immediate_callback

View source

add_immediate_callback(
    callback, *args, **kwds
)

check_success

View source

check_success()

complete

View source

complete()

done

View source

done()

dump

View source

dump()

dump_stack

View source

dump_stack()

get_exception

View source

get_exception()

get_result

View source

get_result()

get_traceback

View source

get_traceback()

putq

View source

putq(
    value
)

set_exception

View source

set_exception(
    exc, tb=None
)

set_result

View source

set_result(
    result
)

wait

View source

wait()

wait_all

View source

@classmethod
wait_all(
    futures
)

wait_any

View source

@classmethod
wait_any(
    futures
)

FINISHING 2
IDLE 0
RUNNING 1