exit codes for error/timeout

Author: cryi

src/ascend.lua

@@ -34,10 +34,18 @@ tasks.add(services.healthcheck())
 
 local end_time = timeout and os.time() + timeout or nil
 log_info("ascend started")
-tasks.run({ stopOnError = true , end_time = end_time })
+local stop_reason = tasks.run({ stopOnError = true , end_time = end_time })
 
 tasks.clear()
 tasks.add(services.stop_all())
 tasks.run({ ignoreStop = true, stopOnEmpty = true })
 
 log_info("ascend stopped")
+
+if stop_reason == "error" then
+	os.exit(1)
+end
+
+if stop_reason == "timeout" then
+	os.exit(2)
+end

src/ascend/tasks.lua

@@ -27,15 +27,25 @@ function tasks.add(task)
 	table.insert(taskQueue, task)
 end
 
+---@alias StopReason "error" | "empty" | "timeout" | "requested"
+
 --- run all tasks in the task queue
 ---@param options TaskPoolOptions
+---@return StopReason
 function tasks.run(options)
 	if not options then
 		options = {}
 	end
 
-	while options.ignoreStop or not is_stop_requested() and not timed_out(options.end_time) do
-		local stop = false
+	while true do
+		if not options.ignoreStop and is_stop_requested() then
+			return "requested"
+		end
+		if timed_out(options.end_time) then
+			return "timeout"
+		end
+
+		local error_occured = false
 
 		local newTaskQueue = {}
 		for _, task in ipairs(taskQueue) do
@@ -46,7 +56,7 @@ function tasks.run(options)
 			if not ok then
 				log_error("!!! task failed !!!", { error = err })
 				if options.stopOnError then
-					stop = true
+					error_occured = true
 					break
 				end
 			end
@@ -55,8 +65,11 @@ function tasks.run(options)
 		end
 
 		taskQueue = newTaskQueue
-		if stop or (options.stopOnEmpty and #taskQueue == 0) then
-			break
+		if error_occured then
+			return "error"
+		end
+		if (options.stopOnEmpty and #taskQueue == 0) then
+			return "empty"
 		end
 		os.sleep(100, 1000)
 	end

src/version-info.lua

@@ -1,5 +1,5 @@
-local ASCEND_VERSION = "0.7.3"
+local ASCEND_VERSION = "0.7.4"
 
 return {
-	VERSION = ASCEND_VERSION,
+	VERSION = ASCEND_VERSION
 }