We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a42cd4f commit 79d2f02Copy full SHA for 79d2f02
‎pipeline/repository/weather.py
@@ -39,7 +39,10 @@ def handle_weather(self, weather: Weather) -> None:
39
if existing_weather := (
40
self.session.query(Weather).filter_by(date=weather.date).first()
41
):
42
- self.update(Weather(**existing_weather.__dict__))
+ for key, value in weather.__dict__.items():
43
+ if key != "_sa_instance_state":
44
+ setattr(existing_weather, key, value)
45
+ self.update(existing_weather)
46
else:
47
self.add(weather)
48
except IntegrityError as exc:
0 commit comments