Skip to content

Commit d71fe73

Browse files
committed
v3.2.18-rc2
fixed issue with sometimes task status not getting updated when also setting complete
1 parent 4c1c28d commit d71fe73

File tree

2 files changed

+11
-3
lines changed

2 files changed

+11
-3
lines changed

VERSION

+1-1
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
3.2.18-rc1
1+
3.2.18-rc2

mythic-docker/src/rabbitmq/recv_pt_task_create_response.go

+10-2
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,11 @@ func processPtTaskCreateMessages(msg amqp.Delivery) {
9393
}
9494
9595
*/
96-
task.Status = PT_TASK_FUNCTION_STATUS_COMPLETED
96+
if payloadMsg.TaskStatus != nil {
97+
task.Status = *payloadMsg.TaskStatus
98+
} else {
99+
task.Status = PT_TASK_FUNCTION_STATUS_COMPLETED
100+
}
97101
task.Timestamp = time.Now().UTC()
98102
updateColumns = append(updateColumns, "timestamp=:timestamp")
99103
task.StatusTimestampSubmitted.Valid = true
@@ -106,7 +110,11 @@ func processPtTaskCreateMessages(msg amqp.Delivery) {
106110
if task.Status == PT_TASK_FUNCTION_STATUS_PREPROCESSING && payloadMsg.Success {
107111
task.Status = PT_TASK_FUNCTION_STATUS_OPSEC_POST
108112
} else if task.Status == PT_TASK_FUNCTION_STATUS_PREPROCESSING && !payloadMsg.Success {
109-
task.Status = PT_TASK_FUNCTION_STATUS_PREPROCESSING_ERROR
113+
if payloadMsg.TaskStatus != nil {
114+
task.Status = *payloadMsg.TaskStatus
115+
} else {
116+
task.Status = PT_TASK_FUNCTION_STATUS_PREPROCESSING_ERROR
117+
}
110118
}
111119
}
112120
updateColumns = append(updateColumns, "status=:status")

0 commit comments

Comments
 (0)