Decider

botoflow.decider.decider

class botoflow.decider.decider.Decider(worker, domain, task_list, get_workflow, identity, _Poller=<class 'botoflow.decider.decision_task_poller.DecisionTaskPoller'>)

Parameters

• worker (awsflow.workers.base_worker.BaseWorker) --
• domain (str) --
• task_list (str) --
• get_workflow (function) --
• identity (str) --
• _Poller (awsflow.decider.decision_task_poller.DecisionTaskPoller) --

decide()

get_next_id()

handle_execute_timer(seconds)

botoflow.decider.decision_task_poller

class botoflow.decider.decision_task_poller.DecisionTask(poller, decision_dict)

events

class botoflow.decider.decision_task_poller.DecisionTaskPoller(worker, domain, task_list, identity)

Polls for decisions

poll()

Returns a paginating DecisionTask generator

single_poll(next_page_token=None)

class botoflow.decider.decision_task_poller.EventsIterator(poller, decision_dict)

contains(event_type)

Parameters

event_type (awsflow.history_events.event_bases.EventBase) -- type of event to search for

Returns

True if given event type exists among events

Return type

bool

botoflow.decider.workflow_replayer

class botoflow.decider.workflow_replayer.ReplayingDecisionTaskPoller(worker, domain, task_list, identity)

single_poll(next_page_token=None)

class botoflow.decider.workflow_replayer.WorkflowReplayer

from_history_dump(workflows, workflow_description, history_pages)

replay()