def add_snapshot()

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()