@ -36,7 +36,6 @@ def _set_prom_info():
|
|||||||
@actor(description=_("Update latest version info"))
|
@actor(description=_("Update latest version info"))
|
||||||
def update_latest_version():
|
def update_latest_version():
|
||||||
self: Task = CurrentTask.get_task()
|
self: Task = CurrentTask.get_task()
|
||||||
raise RuntimeError("whatever")
|
|
||||||
if CONFIG.get_bool("disable_update_check"):
|
if CONFIG.get_bool("disable_update_check"):
|
||||||
cache.set(VERSION_CACHE_KEY, VERSION_NULL, VERSION_CACHE_TIMEOUT)
|
cache.set(VERSION_CACHE_KEY, VERSION_NULL, VERSION_CACHE_TIMEOUT)
|
||||||
self.info("Version check disabled.")
|
self.info("Version check disabled.")
|
||||||
|
@ -49,6 +49,7 @@ class LoggingMiddleware(Middleware):
|
|||||||
task: Task = message.options["task"]
|
task: Task = message.options["task"]
|
||||||
task.log(str(type(self)), TaskStatus.INFO, "Task is being processed")
|
task.log(str(type(self)), TaskStatus.INFO, "Task is being processed")
|
||||||
|
|
||||||
|
# TODO: also after_skip_message
|
||||||
def after_process_message(
|
def after_process_message(
|
||||||
self,
|
self,
|
||||||
broker: Broker,
|
broker: Broker,
|
||||||
|
Reference in New Issue
Block a user