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.

  • parent (Future) : The parent future if one exists A default value of None should be passed in if app is not launched
  • 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


__init__(parent[, tid, stdout, stderr]) Initialize the AppFuture.
add_done_callback(fn) Attaches a callable that will be called when the future finishes.
cancel() Cancel the future if possible.
cancelled() Return True if the future was cancelled.
done() Check if the future is done.
exception([timeout]) Return the exception raised by the call that the future represents.
parent_callback(executor_fu) Callback from executor future to update the parent.
result([timeout]) Result.
running() Return True if the future is currently executing.
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.