Skip to content

tasks

django_spire.contrib.progress.tasks

ParallelTask

Source code in django_spire/contrib/progress/tasks.py 
14
15
16
17
18
19
20
21
22
23
24
25
def __init__(self, session: ProgressSession, task_id: str, future: Any) -> None:
    self._future = future
    self._session = session
    self._task_id = task_id

    self._session.start(task_id)

    thread = threading.Thread(
        target=self._wait_for_completion,
        daemon=True,
    )
    thread.start()

result property

SequentialTask

Source code in django_spire/contrib/progress/tasks.py 
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
def __init__(
    self,
    session: ProgressSession,
    task_id: str,
    func: Callable,
    *args: Any,
    **kwargs: Any,
) -> None:
    self._exception: Exception | None = None
    self._result: Any = None
    self._session = session
    self._task_id = task_id

    self._session.start(task_id)

    try:
        self._result = func(*args, **kwargs)
        self._session.complete(task_id)
    except Exception as e:
        self._exception = e
        self._session.error(task_id)

result property