BatchPoolFuture

class hailtop.batch.batch_pool_executor.BatchPoolFuture(executor, batch, job, output_file)

Bases: object

Methods

add_done_callback	NOT IMPLEMENTED
async_cancel	Asynchronously cancel this job.
async_result	Asynchronously wait until the job is complete.
cancel	Cancel this job if it has not yet been cancelled.
cancelled	Returns True if cancel() was called before a value was produced.
done	Returns True if the function is complete and not cancelled.
exception	Block until the job is complete and raise any exceptions.
result	Blocks until the job is complete.
running	Always returns False.

add_done_callback(_)

NOT IMPLEMENTED

async async_cancel()

Asynchronously cancel this job.

True is returned if the job is cancelled. False is returned if the job has already completed.

async async_result(timeout=None)

Asynchronously wait until the job is complete.

If the job has been cancelled, this method raises a concurrent.futures.CancelledError.

If the job has timed out, this method raises an :class”.concurrent.futures.TimeoutError.

Parameters:

timeout (Union[int, float, None]) – Wait this long before raising a timeout error.

cancel()

Cancel this job if it has not yet been cancelled.

True is returned if the job is cancelled. False is returned if the job has already completed.

cancelled()

Returns True if cancel() was called before a value was produced.

done()

Returns True if the function is complete and not cancelled.

exception(timeout=None)

Block until the job is complete and raise any exceptions.

result(timeout=None)

Blocks until the job is complete.

If the job has been cancelled, this method raises a concurrent.futures.CancelledError.

If the job has timed out, this method raises an concurrent.futures.TimeoutError.

Parameters:

timeout (Union[int, float, None]) – Wait this long before raising a timeout error.

running()

Always returns False.

This future can always be cancelled, so this function always returns False.