Method _set_state

SpiffWorkflow/task.py:291–303

Force set the state on a task

(self, value)

            self.workflow._remove_task(task.id)

    def _set_state(self, value):
        """Force set the state on a task"""

        if value != self.state:
            elapsed = time.time() - self.last_state_change
            self.last_state_change = time.time()
            self._state = value
            logger.info(
                f'State changed to {TaskState.get_name(value)}',
                extra=self.collect_log_extras({'elapsed': elapsed})
            )
        else:
            logger.debug(f'State set to {TaskState.get_name(value)}', extra=self.collect_log_extras())

    def _assign_new_thread_id(self, recursive=True):
        """Assigns a new thread id to the task."""