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(fn)

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.