soonq/broker.py
def dequeue(self, queue_name):
        """Dequeue the next item (item with lowest position number) from
        the queue with the given name and return it.
        """
        con = sqlite3.connect(str(DB_PATH))
        con.row_factory = sqlite3.Row
        with con:
            c = con.execute(
                f"""
                SELECT
                    task_id,
                    queue_name,
                    position,
                    published,
                    args,
                    kwargs
                FROM {QUEUE_TABLENAME}
                WHERE queue_name = ?
                ORDER BY position ASC
                """,
                (queue_name,),
            )
            dequeued_item = c.fetchone()
            if dequeued_item:
                item_id = dequeued_item["task_id"]
                con.execute(
                    f"""
                    DELETE FROM {QUEUE_TABLENAME}
                    WHERE task_id = ?
                    """,
                    (item_id,),
                )
        con.close()
        return dequeued_item
Dequeue the next item (item with lowest position number) from
        the queue with the given name and return it.
        
Dequeue the next item (item with lowest position number) from
the queue with the given name and return it.
Dequeue the next item ( item with lowest position number ) from the queue with the given name and return it .
def dequeue(self, queue_name):
        con = sqlite3.connect(str(DB_PATH))
        con.row_factory = sqlite3.Row
        with con:
            c = con.execute(
                f"""
                SELECT
                    task_id,
                    queue_name,
                    position,
                    published,
                    args,
                    kwargs
                FROM {QUEUE_TABLENAME}
                WHERE queue_name = ?
                ORDER BY position ASC
                """,
                (queue_name,),
            )
            dequeued_item = c.fetchone()
            if dequeued_item:
                item_id = dequeued_item["task_id"]
                con.execute(
                    f"""
                    DELETE FROM {QUEUE_TABLENAME}
                    WHERE task_id = ?
                    """,
                    (item_id,),
                )
        con.close()
        return dequeued_item
def dequeue ( self , queue_name ) : con = sqlite3 . connect ( str ( DB_PATH ) ) con . row_factory = sqlite3 . Row with con : c = con . execute ( f"""
                SELECT
                    task_id,
                    queue_name,
                    position,
                    published,
                    args,
                    kwargs
                FROM {QUEUE_TABLENAME}
                WHERE queue_name = ?
                ORDER BY position ASC
                """ , ( queue_name , ) , ) dequeued_item = c . fetchone ( ) if dequeued_item : item_id = dequeued_item [ "task_id" ] con . execute ( f"""
                    DELETE FROM {QUEUE_TABLENAME}
                    WHERE task_id = ?
                    """ , ( item_id , ) , ) con . close ( ) return dequeued_item
Dequeue the next item (item with lowest position number) from
the queue with the given name and return it.
Dequeue the next item ( item with lowest position number ) from the queue with the given name and return it .
"""Dequeue the next item (item with lowest position number) from
        the queue with the given name and return it.
        """
self
queue_name