@@ -44,7 +44,7 @@ class Thread(threading.Thread, Generic[_Target_P, _Target_T]):
44
44
45
45
status : ThreadStatus
46
46
hooks : List [HookFunction ]
47
- returned_value : Data_Out
47
+ _returned_value : Data_Out
48
48
49
49
errors : List [Exception ]
50
50
ignore_errors : Sequence [type [Exception ]]
@@ -86,7 +86,7 @@ def __init__(
86
86
:param **: These are arguments parsed to `thread.Thread`
87
87
"""
88
88
_target = self ._wrap_target (target )
89
- self .returned_value = None
89
+ self ._returned_value = None
90
90
self .status = 'Idle'
91
91
self .hooks = []
92
92
@@ -116,7 +116,7 @@ def wrapper(*args: _Target_P.args, **kwargs: _Target_P.kwargs) -> Union[_Target_
116
116
Threads .add (self )
117
117
118
118
try :
119
- self .returned_value = target (* args , ** kwargs )
119
+ self ._returned_value = target (* args , ** kwargs )
120
120
except Exception as e :
121
121
if not any (isinstance (e , ignore ) for ignore in self .ignore_errors ):
122
122
self .status = 'Errored'
@@ -135,7 +135,7 @@ def _invoke_hooks(self) -> None:
135
135
errors : List [Tuple [Exception , str ]] = []
136
136
for hook in self .hooks :
137
137
try :
138
- hook (self .returned_value )
138
+ hook (self ._returned_value )
139
139
except Exception as e :
140
140
if not any (isinstance (e , ignore ) for ignore in self .ignore_errors ):
141
141
errors .append ((
@@ -196,7 +196,7 @@ def result(self) -> _Target_T:
196
196
197
197
self ._handle_exceptions ()
198
198
if self .status in ['Invoking hooks' , 'Completed' ]:
199
- return self .returned_value
199
+ return self ._returned_value
200
200
else :
201
201
raise exceptions .ThreadStillRunningError ()
202
202
0 commit comments