Record emitted events to IPC database for asynchronous I/O communication with the parent process
(self, record)
| 272 | |
| 273 | class LogRecorder(logging.StreamHandler): |
| 274 | def emit(self, record): |
| 275 | """ |
| 276 | Record emitted events to IPC database for asynchronous I/O |
| 277 | communication with the parent process |
| 278 | """ |
| 279 | conf.databaseCursor.execute("INSERT INTO logs VALUES(NULL, ?, ?, ?, ?)", (conf.taskid, time.strftime("%X"), record.levelname, str(record.msg % record.args if record.args else record.msg))) |
| 280 | |
| 281 | def setRestAPILog(): |
| 282 | if conf.api: |