Index

A

AbstractDataConverter (class in botoflow.data_converter.abstract_data_converter) activities() (in module botoflow.decorators) activity() (in module botoflow.decorators) activity_options (class in botoflow.options) ActivityContext (class in botoflow.context.activity_context) ActivityDecisionBase (class in botoflow.decisions.decision_bases) ActivityEventBase (class in botoflow.history_events.event_bases) ActivityFunc (class in botoflow.decorator_descriptors) ActivityTask (class in botoflow.workers.activity_task) ActivityTaskCanceled (class in botoflow.history_events.events) ActivityTaskCanceledError ActivityTaskCancelRequested (class in botoflow.history_events.events)

ActivityTaskCompleted (class in botoflow.history_events.events) ActivityTaskError ActivityTaskFailed (class in botoflow.history_events.events) ActivityTaskFailedError ActivityTaskScheduled (class in botoflow.history_events.events) ActivityTaskStarted (class in botoflow.history_events.events) ActivityTaskTimedOut (class in botoflow.history_events.events) ActivityTaskTimedOutError ActivityWorker (class in botoflow.workers.activity_worker) AsyncEventLoop (class in botoflow.core.async_event_loop) attribute_key (botoflow.history_events.events.ActivityTaskCanceled attribute) (botoflow.history_events.events.ActivityTaskCancelRequested attribute) (botoflow.history_events.events.ActivityTaskCompleted attribute) (botoflow.history_events.events.ActivityTaskFailed attribute) (botoflow.history_events.events.ActivityTaskScheduled attribute) (botoflow.history_events.events.ActivityTaskStarted attribute) (botoflow.history_events.events.ActivityTaskTimedOut attribute) (botoflow.history_events.events.CancelTimerFailed attribute) (botoflow.history_events.events.CancelWorkflowExecutionFailed attribute) (botoflow.history_events.events.ChildWorkflowExecutionCanceled attribute) (botoflow.history_events.events.ChildWorkflowExecutionCompleted attribute) (botoflow.history_events.events.ChildWorkflowExecutionFailed attribute) (botoflow.history_events.events.ChildWorkflowExecutionStarted attribute) (botoflow.history_events.events.ChildWorkflowExecutionTerminated attribute) (botoflow.history_events.events.ChildWorkflowExecutionTimedOut attribute) (botoflow.history_events.events.CompleteWorkflowExecutionFailed attribute) (botoflow.history_events.events.ContinueAsNewWorkflowExecutionFailed attribute) (botoflow.history_events.events.DecisionTaskCompleted attribute) (botoflow.history_events.events.DecisionTaskScheduled attribute) (botoflow.history_events.events.DecisionTaskStarted attribute) (botoflow.history_events.events.DecisionTaskTimedOut attribute) (botoflow.history_events.events.ExternalWorkflowExecutionCancelRequested attribute) (botoflow.history_events.events.FailWorkflowExecutionFailed attribute) (botoflow.history_events.events.MarkerRecorded attribute) (botoflow.history_events.events.RequestCancelActivityTaskFailed attribute) (botoflow.history_events.events.RequestCancelExternalWorkflowExecutionFailed attribute) (botoflow.history_events.events.RequestCancelExternalWorkflowExecutionInitiated attribute) (botoflow.history_events.events.ScheduleActivityTaskFailed attribute) (botoflow.history_events.events.SignalExternalWorkflowExecutionFailed attribute) (botoflow.history_events.events.SignalExternalWorkflowExecutionInitiated attribute) (botoflow.history_events.events.StartChildWorkflowExecutionFailed attribute) (botoflow.history_events.events.StartChildWorkflowExecutionInitiated attribute) (botoflow.history_events.events.StartTimerFailed attribute) (botoflow.history_events.events.TimerCanceled attribute) (botoflow.history_events.events.TimerFired attribute) (botoflow.history_events.events.TimerStarted attribute) (botoflow.history_events.events.WorkflowExecutionCancelRequested attribute) (botoflow.history_events.events.WorkflowExecutionCanceled attribute) (botoflow.history_events.events.WorkflowExecutionCompleted attribute) (botoflow.history_events.events.WorkflowExecutionContinuedAsNew attribute) (botoflow.history_events.events.WorkflowExecutionFailed attribute) (botoflow.history_events.events.WorkflowExecutionSignaled attribute) (botoflow.history_events.events.WorkflowExecutionStarted attribute) (botoflow.history_events.events.WorkflowExecutionTimedOut attribute)

B

BaseWorker (class in botoflow.workers.base_worker) botoflow.activity_retrying (module) botoflow.constants (module) botoflow.context.activity_context (module) botoflow.context.decision_context (module) botoflow.context.start_workflow_context (module) botoflow.core.async_event_loop (module) botoflow.core.async_traceback (module) botoflow.core.decorators (module) botoflow.core.exceptions (module) botoflow.core.future (module) botoflow.data_converter.abstract_data_converter (module) botoflow.data_converter.json_data_converter (module) botoflow.data_converter.pickle_data_converter (module) botoflow.decider.decider (module) botoflow.decider.decision_task_poller (module) botoflow.decider.workflow_replayer (module) botoflow.decisions.decision_bases (module) botoflow.decisions.decision_list (module) botoflow.decisions.decisions (module) botoflow.decorator_descriptors (module) botoflow.decorators (module) botoflow.exceptions (module) botoflow.flow_types (module)

botoflow.history_events.event_bases (module) botoflow.history_events.events (module) botoflow.logging_filters (module) botoflow.options (module) botoflow.swf_exceptions (module) botoflow.utils (module) botoflow.workers.activity_task (module) botoflow.workers.activity_worker (module) botoflow.workers.base_worker (module) botoflow.workers.multiprocessing_activity_executor (module) botoflow.workers.multiprocessing_executor (module) botoflow.workers.multiprocessing_workflow_executor (module) botoflow.workers.swf_op_callable (module) botoflow.workers.threaded_activity_executor (module) botoflow.workers.threaded_executor (module) botoflow.workers.threaded_workflow_executor (module) botoflow.workers.workflow_worker (module) botoflow.workflow_definition (module) botoflow.workflow_execution (module) botoflow.workflow_starting (module) botoflow.workflow_time (module) BotoflowError BotoflowFilter (class in botoflow.logging_filters)

C

call (botoflow.activity_retrying.Retrying attribute) camel_keys_to_snake_case() (in module botoflow.utils) cancel() (botoflow.workflow_definition.WorkflowDefinition method) cancellation_handler (botoflow.workflow_definition.WorkflowDefinition attribute) CancellationError CancelledError CancelTimer (class in botoflow.decisions.decisions) CancelTimerFailed (class in botoflow.history_events.events) CancelWorkflowExecution (class in botoflow.decisions.decisions) CancelWorkflowExecutionFailed (class in botoflow.history_events.events) cause (botoflow.exceptions.ActivityTaskCanceledError attribute) CHILD_ABANDON (in module botoflow.constants) CHILD_REQUEST_CANCEL (in module botoflow.constants) CHILD_TERMINATE (in module botoflow.constants) ChildWorkflowError ChildWorkflowEventBase (class in botoflow.history_events.event_bases)

ChildWorkflowExecutionCanceled (class in botoflow.history_events.events) ChildWorkflowExecutionCompleted (class in botoflow.history_events.events) ChildWorkflowExecutionFailed (class in botoflow.history_events.events) ChildWorkflowExecutionStarted (class in botoflow.history_events.events) ChildWorkflowExecutionTerminated (class in botoflow.history_events.events) ChildWorkflowExecutionTimedOut (class in botoflow.history_events.events) ChildWorkflowFailedError ChildWorkflowTerminatedError ChildWorkflowTimedOutError client (botoflow.workers.base_worker.BaseWorker attribute) CompleteWorkflowExecution (class in botoflow.decisions.decisions) CompleteWorkflowExecutionFailed (class in botoflow.history_events.events) contains() (botoflow.decider.decision_task_poller.EventsIterator method) ContinueAsNewWorkflowExecution (class in botoflow.decisions.decisions) ContinueAsNewWorkflowExecutionFailed (class in botoflow.history_events.events) coroutine() (in module botoflow.core.decorators)

D

daemon_coroutine() (in module botoflow.core.decorators) DAYS (in module botoflow.constants) decide() (botoflow.decider.decider.Decider method) Decider (class in botoflow.decider.decider) DecisionBase (class in botoflow.decisions.decision_bases) DecisionBase.decision (in module botoflow.decisions.decision_bases) DecisionContext (class in botoflow.context.decision_context) DecisionEventBase (class in botoflow.history_events.event_bases) DecisionException DecisionExceptionWithTracebackMixIn (class in botoflow.exceptions) DecisionList (class in botoflow.decisions.decision_list) DecisionTask (class in botoflow.decider.decision_task_poller)

DecisionTaskCompleted (class in botoflow.history_events.events) DecisionTaskEventBase (class in botoflow.history_events.event_bases) DecisionTaskPoller (class in botoflow.decider.decision_task_poller) DecisionTaskScheduled (class in botoflow.history_events.events) DecisionTaskStarted (class in botoflow.history_events.events) DecisionTaskTimedOut (class in botoflow.history_events.events) DefaultUndefinedError delete_decision() (botoflow.decisions.decision_list.DecisionList method) domain (botoflow.workers.base_worker.BaseWorker attribute) DomainAlreadyExistsError DomainDeprecatedError dumps() (botoflow.data_converter.abstract_data_converter.AbstractDataConverter method) (botoflow.data_converter.json_data_converter.JSONDataConverter method) (botoflow.data_converter.pickle_data_converter.PickleDataConverter method)

E

EventBase (class in botoflow.history_events.event_bases) events (botoflow.decider.decision_task_poller.DecisionTask attribute) EventsIterator (class in botoflow.decider.decision_task_poller) execute() (in module botoflow.decorators) ExternalWorkflowError

ExternalWorkflowEventBase (class in botoflow.history_events.event_bases) ExternalWorkflowExecutionCancelRequested (class in botoflow.history_events.events) extract_tb() (in module botoflow.core.async_traceback) extract_workflow_details_from_class() (in module botoflow.utils) extract_workflows_dict() (in module botoflow.utils)

F

FailWorkflowExecution (class in botoflow.decisions.decisions) FailWorkflowExecutionFailed (class in botoflow.history_events.events) filter() (botoflow.logging_filters.BotoflowFilter method)

format_exc() (botoflow.exceptions.DecisionExceptionWithTracebackMixIn method) (in module botoflow.core.async_traceback) from_history_dump() (botoflow.decider.workflow_replayer.WorkflowReplayer method)

G

GenericWorkflowWorker (class in botoflow.workers.workflow_worker) get_next_id() (botoflow.decider.decider.Decider method)

get_workflow_entrypoint() (in module botoflow.workers.workflow_worker)

H

handle_execute_timer() (botoflow.decider.decider.Decider method) has_decision_type() (botoflow.decisions.decision_list.DecisionList method)

heartbeat() (botoflow.context.activity_context.ActivityContext method) HOURS (in module botoflow.constants)

I

identity (botoflow.workers.base_worker.BaseWorker attribute) initializer (botoflow.workers.multiprocessing_executor.MultiprocessingExecutor attribute) (botoflow.workers.threaded_executor.ThreadedExecutor attribute) InternalFailureError

is_replaying() (in module botoflow.workflow_time) is_running (botoflow.workers.multiprocessing_executor.MultiprocessingExecutor attribute) (botoflow.workers.threaded_executor.ThreadedExecutor attribute)

J

join() (botoflow.workers.multiprocessing_executor.MultiprocessingExecutor method) (botoflow.workers.threaded_executor.ThreadedExecutor method)

JSONDataConverter (class in botoflow.data_converter.json_data_converter)

L

LimitExceededError

loads() (botoflow.data_converter.abstract_data_converter.AbstractDataConverter method) (botoflow.data_converter.json_data_converter.JSONDataConverter method) (botoflow.data_converter.pickle_data_converter.PickleDataConverter method)

M

manual_activity() (in module botoflow.decorators) MarkerEventBase (class in botoflow.history_events.event_bases) MarkerRecorded (class in botoflow.history_events.events) MINUTES (in module botoflow.constants)

MultiprocessingActivityExecutor (class in botoflow.workers.multiprocessing_activity_executor) MultiprocessingExecutor (class in botoflow.workers.multiprocessing_executor) MultiprocessingWorkflowExecutor (class in botoflow.workers.multiprocessing_workflow_executor)

N

name (botoflow.utils.WorkflowDetails attribute)

NO_DEFAULT_TASK_LIST (in module botoflow.constants)

O

OperationNotPermittedError

P

pairwise() (in module botoflow.utils) PickleDataConverter (class in botoflow.data_converter.pickle_data_converter) poll() (botoflow.decider.decision_task_poller.DecisionTaskPoller method)

poll_for_activities() (botoflow.workers.activity_worker.ActivityWorker method) print_exc() (botoflow.exceptions.DecisionExceptionWithTracebackMixIn method) (in module botoflow.core.async_traceback) Python Enhancement Proposals PEP 0380 PEP 3156, [1]

R

random_sha1_hash() (in module botoflow.utils) RecordMarker (class in botoflow.decisions.decisions) RecordMarkerDecisionBase (class in botoflow.decisions.decision_bases) registration_options (botoflow.utils.WorkflowDetails attribute) replay() (botoflow.decider.workflow_replayer.WorkflowReplayer method) ReplayingDecisionTaskPoller (class in botoflow.decider.workflow_replayer) request_heartbeat() (botoflow.workers.activity_worker.ActivityWorker method) RequestCancelActivityTask (class in botoflow.decisions.decisions) RequestCancelActivityTaskFailed (class in botoflow.history_events.events) RequestCancelActivityTaskFailedError RequestCancelExternalWorkflowDecisionBase (class in botoflow.decisions.decision_bases)

RequestCancelExternalWorkflowExecution (class in botoflow.decisions.decisions) RequestCancelExternalWorkflowExecutionFailed (class in botoflow.history_events.events) RequestCancelExternalWorkflowExecutionFailedError RequestCancelExternalWorkflowExecutionInitiated (class in botoflow.history_events.events) retry_activity() (in module botoflow.decorators) RetryError Retrying (class in botoflow.activity_retrying) run() (botoflow.workers.activity_worker.ActivityWorker method) (botoflow.workers.base_worker.BaseWorker method) (botoflow.workers.workflow_worker.GenericWorkflowWorker method) run_id (botoflow.workflow_execution.WorkflowExecution attribute) run_once() (botoflow.workers.activity_worker.ActivityWorker method) (botoflow.workers.base_worker.BaseWorker method) (botoflow.workers.workflow_worker.GenericWorkflowWorker method)

S

ScheduleActivityTask (class in botoflow.decisions.decisions) ScheduleActivityTaskFailed (class in botoflow.history_events.events) ScheduleActivityTaskFailedError SECONDS (in module botoflow.constants) signal() (in module botoflow.decorators) SignalExternalWorkflowExecution (class in botoflow.decisions.decisions) SignalExternalWorkflowExecutionDecisionBase (class in botoflow.decisions.decision_bases) SignalExternalWorkflowExecutionFailed (class in botoflow.history_events.events) SignalExternalWorkflowExecutionInitiated (class in botoflow.history_events.events) SignalFunc (class in botoflow.decorator_descriptors) single_poll() (botoflow.decider.decision_task_poller.DecisionTaskPoller method) (botoflow.decider.workflow_replayer.ReplayingDecisionTaskPoller method) skip_registration (botoflow.utils.WorkflowDetails attribute) sleep() (in module botoflow.workflow_time) snake_keys_to_camel_case() (in module botoflow.utils) start() (botoflow.workers.multiprocessing_activity_executor.MultiprocessingActivityExecutor method) (botoflow.workers.multiprocessing_executor.MultiprocessingExecutor method) (botoflow.workers.multiprocessing_workflow_executor.MultiprocessingWorkflowExecutor method) (botoflow.workers.threaded_activity_executor.ThreadedActivityExecutor method) (botoflow.workers.threaded_executor.ThreadedExecutor method) (botoflow.workers.threaded_workflow_executor.ThreadedWorkflowExecutor method)

StartChildWorkflowExecution (class in botoflow.decisions.decisions) StartChildWorkflowExecutionDecisionBase (class in botoflow.decisions.decision_bases) StartChildWorkflowExecutionFailed (class in botoflow.history_events.events) StartChildWorkflowExecutionFailedError StartChildWorkflowExecutionInitiated (class in botoflow.history_events.events) StartTimer (class in botoflow.decisions.decisions) StartTimerFailed (class in botoflow.history_events.events) StartWorkflowContext (class in botoflow.context.start_workflow_context) stop() (botoflow.workers.multiprocessing_executor.MultiprocessingExecutor method) (botoflow.workers.threaded_executor.ThreadedExecutor method) str_or_NONE() (in module botoflow.utils) swf_event_to_object() (in module botoflow.history_events.events) swf_exception_wrapper() (in module botoflow.swf_exceptions) SWFOp (class in botoflow.workers.swf_op_callable) SWFResponseError

T

task_list (botoflow.workers.base_worker.BaseWorker attribute) ThreadedActivityExecutor (class in botoflow.workers.threaded_activity_executor) ThreadedExecutor (class in botoflow.workers.threaded_executor) ThreadedWorkflowExecutor (class in botoflow.workers.threaded_workflow_executor) ThrottlingException time() (in module botoflow.workflow_time) TimerCanceled (class in botoflow.history_events.events)

TimerDecisionBase (class in botoflow.decisions.decision_bases) TimerEventBase (class in botoflow.history_events.event_bases) TimerFired (class in botoflow.history_events.events) TimerStarted (class in botoflow.history_events.events) to_swf() (botoflow.decisions.decision_list.DecisionList method) TypeAlreadyExistsError TypeDeprecatedError

U

unhandled_exception_handler (botoflow.workers.base_worker.BaseWorker attribute) UnknownResourceError

UnrecognizedClientException USE_WORKER_TASK_LIST (in module botoflow.constants)

V

ValidationException

version (botoflow.utils.WorkflowDetails attribute)

W

wait_for_completion() (botoflow.workflow_starting.workflow_starter method) WEEKS (in module botoflow.constants) workflow() (in module botoflow.decorators) workflow_execution (botoflow.context.activity_context.ActivityContext attribute) (botoflow.context.decision_context.DecisionContext attribute) (botoflow.workflow_definition.WorkflowDefinition attribute) workflow_id (botoflow.workflow_execution.WorkflowExecution attribute) workflow_options (class in botoflow.options) workflow_result (botoflow.workflow_definition.WorkflowDefinition attribute) workflow_starter (botoflow.context.start_workflow_context.StartWorkflowContext attribute) (class in botoflow.workflow_starting) workflow_state (botoflow.workflow_definition.WorkflowDefinition attribute) WorkflowDecisionBase (class in botoflow.decisions.decision_bases) WorkflowDefinition (class in botoflow.workflow_definition) WorkflowDetails (class in botoflow.utils) WorkflowError WorkflowEventBase (class in botoflow.history_events.event_bases) WorkflowExecuteFunc (class in botoflow.decorator_descriptors)

WorkflowExecution (class in botoflow.workflow_execution) WorkflowExecutionAlreadyStartedError WorkflowExecutionCanceled (class in botoflow.history_events.events) WorkflowExecutionCancelRequested (class in botoflow.history_events.events) WorkflowExecutionCompleted (class in botoflow.history_events.events) WorkflowExecutionContinuedAsNew (class in botoflow.history_events.events) WorkflowExecutionFailed (class in botoflow.history_events.events) WorkflowExecutionSignaled (class in botoflow.history_events.events) WorkflowExecutionStarted (class in botoflow.history_events.events) WorkflowExecutionTimedOut (class in botoflow.history_events.events) WorkflowFailedError WorkflowReplayer (class in botoflow.decider.workflow_replayer) WorkflowTerminatedError WorkflowTimedOutError WorkflowWorker (class in botoflow.workers.workflow_worker)