in purchase-function/src/inventory.py [0:0]
def add_snapshot(self, items, related_order_id=None):
conn = self._get_db_connection()
try:
cursor = conn.cursor()
cursor.execute('''
INSERT INTO snapshots (timestamp, items, related_order_id)
VALUES (?, ?, ?)
''', (
datetime.utcnow(),
json.dumps(items),
related_order_id
))
conn.commit()
conn.close()
except sqlite3.Error as e:
logger.info("conn is closed due to db exception")
conn.close()