def METHOD_NAME(self):
    # Start a workflow execution whose activity task will succeed.
    workflow_id = 'wfid-%.2f' % (time.time(),)
    r = self.conn.start_workflow_execution(self._domain,
                                           workflow_id,
                                           self._workflow_type_name,
                                           self._workflow_type_version,
                                           execution_start_to_close_timeout='20',
                                           input='[600, 15]')
    # Need the run_id to lookup the execution history later.
    run_id = r['runId']
    # Move the workflow execution forward by having the
    # decider schedule an activity task.
    self.run_decider()
    # Run the worker to handle the scheduled activity task.
    self.run_worker()
    # Complete the workflow execution by having the
    # decider close it down.
    self.run_decider()
    # Check that the result was stored in the execution history.
    r = self.conn.get_workflow_execution_history(self._domain,
                                                 run_id, workflow_id,
                                                 reverse_order=True)['events'][0]
    result = r['workflowExecutionCompletedEventAttributes']['result']
    assert json.loads(result) == 615