parsl.dataflow.futures.AppFuture

class parsl.dataflow.futures.AppFuture(parent, tid=None, stdout=None, stderr=None)[source]

An AppFuture points at a Future returned from an Executor.

We are simply wrapping a AppFuture, and adding the specific case where, if the future is resolved i.e file exists, then the DataFuture is assumed to be resolved.

__init__(parent, tid=None, stdout=None, stderr=None)[source]

Initialize the AppFuture.

Args:
  • parent (Future) : The parent future if one exists A default value of None should be passed in if app is not launched
KWargs:
  • tid (Int) : Task id should be any unique identifier. Now Int.
  • stdout (str) : Stdout file of the app.
    Default: None
  • stderr (str) : Stderr file of the app.
    Default: None

Methods

__init__(parent[, tid, stdout, stderr]) Initialize the AppFuture.
add_done_callback(fn)
cancel()
cancelled()
done() Check if the future is done.
exception([timeout])
parent_callback(executor_fu) Callback from executor future to update the parent.
result([timeout]) Result.
running()
set_exception(exception) Sets the result of the future as being the given exception.
set_result(result) Sets the return value of work associated with the future.
set_running_or_notify_cancel() Mark the future as running or process any cancel notifications.
update_parent(fut) Add a callback to the parent to update the state.

Attributes

outputs
stderr
stdout
tid