def METHOD_NAME(
    self,
    *,
    message: LogMessageStr,
    log_level: LogLevelInt,
) -> None:
    publish_event(
        self.logs, TaskLogEvent.from_dask_worker(log=message, log_level=log_level)
    )