diff --git a/scrarls.py b/scrarls.py index bfe1599..c846780 100644 --- a/scrarls.py +++ b/scrarls.py @@ -117,11 +117,20 @@ class SQLAlchemyPipeline: show = session.scalars(stmt).first() print(f"{show=}") if not show: - show = TvShowDB(**item) + show = TvShowDB( + post_id=item["post_id"], + post_title=item["post_title"], + title=item["title"], + date=item["date"], + summary=item["summary"], + image_url=item["image_url"], + links=[LinkDB(link=url) for url in item["download_url"]] + ) session.add(show) else: for key, value in item.items(): - setattr(show, key, value) + if key != "download_url": + setattr(show, key, value) session.commit() except Exception as e: session.rollback()