soonq/broker.py
def add_work(self, item, status, iargs, ikwargs):
        """Add the given item to the work table."""
        con = sqlite3.connect(str(DB_PATH))
        with con:
            con.execute(
                f"""
                INSERT INTO {WORK_TABLENAME} (
                    task_id,
                    queue_name,
                    started,
                    status,
                    args,
                    kwargs
                )
                VALUES (?, ?, ?, ?, ?, ?)
                """,
                (
                    item.task_id,
                    item.task_name,
                    dt.datetime.now(),
                    status,
                    iargs,
                    ikwargs,
                ),
            )
        con.close()
Add the given item to the work table.
Add the given item to the work table.
Add the given item to the work table .
def add_work(self, item, status, iargs, ikwargs):
        con = sqlite3.connect(str(DB_PATH))
        with con:
            con.execute(
                f"""
                INSERT INTO {WORK_TABLENAME} (
                    task_id,
                    queue_name,
                    started,
                    status,
                    args,
                    kwargs
                )
                VALUES (?, ?, ?, ?, ?, ?)
                """,
                (
                    item.task_id,
                    item.task_name,
                    dt.datetime.now(),
                    status,
                    iargs,
                    ikwargs,
                ),
            )
        con.close()
def add_work ( self , item , status , iargs , ikwargs ) : con = sqlite3 . connect ( str ( DB_PATH ) ) with con : con . execute ( f"""
                INSERT INTO {WORK_TABLENAME} (
                    task_id,
                    queue_name,
                    started,
                    status,
                    args,
                    kwargs
                )
                VALUES (?, ?, ?, ?, ?, ?)
                """ , ( item . task_id , item . task_name , dt . datetime . now ( ) , status , iargs , ikwargs , ) , ) con . close ( )
Add the given item to the work table.
Add the given item to the work table .
"""Add the given item to the work table."""
self
item
status
iargs
ikwargs