@@ -109,9 +109,12 @@ class IndexingWatchdogTerminalStatus(str, Enum):
109
109
110
110
OUT_OF_MEMORY = "out_of_memory"
111
111
112
+ PROCESS_SIGNAL_SIGKILL = "process_signal_sigkill"
113
+
112
114
@property
113
115
def code (self ) -> int :
114
116
_ENUM_TO_CODE : dict [IndexingWatchdogTerminalStatus , int ] = {
117
+ IndexingWatchdogTerminalStatus .PROCESS_SIGNAL_SIGKILL : - 9 ,
115
118
IndexingWatchdogTerminalStatus .OUT_OF_MEMORY : 137 ,
116
119
IndexingWatchdogTerminalStatus .BLOCKED_BY_DELETION : 248 ,
117
120
IndexingWatchdogTerminalStatus .BLOCKED_BY_STOP_SIGNAL : 249 ,
@@ -128,7 +131,7 @@ def code(self) -> int:
128
131
@classmethod
129
132
def from_code (cls , code : int ) -> "IndexingWatchdogTerminalStatus" :
130
133
_CODE_TO_ENUM : dict [int , IndexingWatchdogTerminalStatus ] = {
131
- 137 : IndexingWatchdogTerminalStatus .OUT_OF_MEMORY ,
134
+ - 9 : IndexingWatchdogTerminalStatus .PROCESS_SIGNAL_SIGKILL ,
132
135
248 : IndexingWatchdogTerminalStatus .BLOCKED_BY_DELETION ,
133
136
249 : IndexingWatchdogTerminalStatus .BLOCKED_BY_STOP_SIGNAL ,
134
137
250 : IndexingWatchdogTerminalStatus .FENCE_NOT_FOUND ,
@@ -728,7 +731,6 @@ def connector_indexing_task(
728
731
f"Index attempt not found: index_attempt={ index_attempt_id } " ,
729
732
code = IndexingWatchdogTerminalStatus .INDEX_ATTEMPT_MISMATCH .code ,
730
733
)
731
- # attempt_found = True
732
734
733
735
cc_pair = get_connector_credential_pair_from_id (
734
736
db_session = db_session ,
0 commit comments