![]() |
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.
Attributes | |
---|---|
state
|
Methods
add_callback
add_callback(
callback, *args, **kwds
)
add_dependent
add_dependent(
fut
)
add_immediate_callback
add_immediate_callback(
callback, *args, **kwds
)
check_success
check_success()
complete
complete()
done
done()
dump
dump()
dump_stack
dump_stack()
get_exception
get_exception()
get_result
get_result()
get_traceback
get_traceback()
putq
putq(
value
)
set_exception
set_exception(
exc, tb=None
)
set_result
set_result(
result
)
wait
wait()
wait_all
@classmethod
wait_all( futures )
wait_any
@classmethod
wait_any( futures )
Class Variables | |
---|---|
FINISHING |
2
|
IDLE |
0
|
RUNNING |
1
|