1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
|
from typing import Optional, Sequence, Tuple
from parsl.errors import ParslError
class DataFlowException(ParslError):
"""Base class for all exceptions.
Only to be invoked when only a more specific error is not available.
"""
class BadCheckpoint(DataFlowException):
"""Error raised at the end of app execution due to missing output files.
Args:
- reason
Contains:
reason (string)
dependent_exceptions
"""
def __init__(self, reason: str) -> None:
self.reason = reason
def __str__(self) -> str:
return self.reason
class DependencyError(DataFlowException):
"""Error raised if an app cannot run because there was an error
in a dependency.
Args:
- dependent_exceptions_tids: List of exceptions and identifiers for
dependencies which failed. The identifier might be a task ID or
the repr of a non-DFK Future.
- task_id: Task ID of the task that failed because of the dependency error
"""
def __init__(self, dependent_exceptions_tids: Sequence[Tuple[Exception, str]], task_id: int) -> None:
self.dependent_exceptions_tids = dependent_exceptions_tids
self.task_id = task_id
def __str__(self) -> str:
deps = ", ".join(tid for _exc, tid in self.dependent_exceptions_tids)
return f"Dependency failure for task {self.task_id} with failed dependencies from {deps}"
class JoinError(DataFlowException):
"""Error raised if apps joining into a join_app raise exceptions.
There can be several exceptions (one from each joining app),
and JoinError collects them all together.
"""
def __init__(self, dependent_exceptions_tids: Sequence[Tuple[BaseException, Optional[str]]], task_id: int) -> None:
self.dependent_exceptions_tids = dependent_exceptions_tids
self.task_id = task_id
def __str__(self) -> str:
dep_tids = [tid for (exception, tid) in self.dependent_exceptions_tids]
return "Join failure for task {} with failed join dependencies from tasks {}".format(self.task_id, dep_tids)
|
