From 50f62d0b6a17677104f0e4d39c5ff7223c5239b2 Mon Sep 17 00:00:00 2001 From: Dennis Eriksen Date: Mon, 3 Apr 2023 12:23:40 +0200 Subject: adding function to insert state without defining sql --- scripts/common/queue.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) (limited to 'scripts/common/queue.py') diff --git a/scripts/common/queue.py b/scripts/common/queue.py index cb90423..b4fa369 100644 --- a/scripts/common/queue.py +++ b/scripts/common/queue.py @@ -3,20 +3,26 @@ import os import pickle +import logging from litequeue import SQLQueue QUEUE_DB = os.environ.get('el_QUEUE_db', 'litequeue.db') +log = logging.getLogger(__name__) + # Initialize queue q = SQLQueue(QUEUE_DB, maxsize=None) def dbi(sql,values,**kwargs): ''' insert into queue ''' + log.debug('function dbi()') verbose = bool(kwargs['verbose']) if 'verbose' in kwargs else False + log.debug('Inserting into sqlite-queue') q.put(pickle.dumps([sql, values])) if verbose is True: + log.debug('verbose = True') table = sql.split(' ')[2] num = 1 if isinstance(values, tuple) else len(values) - print("Inserted", num, "item(s) into queue for", table) + print("Inserted " + str(num) + " item(s) into queue for " + str(table)) return True -- cgit v1.2.3