Skip to content

Commit

Permalink
fix: Update record access in streams.py for CDK 6.x compatibility
Browse files Browse the repository at this point in the history
Co-Authored-By: Aaron <AJ> Steers <[email protected]>
  • Loading branch information
devin-ai-integration[bot] and aaronsteers committed Feb 1, 2025
1 parent 4ff2d11 commit 7919fce
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -112,7 +112,7 @@ def read_records(self, **kwargs) -> Iterable[Mapping[str, Any]]:
records_remaining_this_loop = min(self.records_per_slice, (self.count - loop_offset))
users = pool.map(self.generator.generate, range(loop_offset, loop_offset + records_remaining_this_loop))
for user in users:
updated_at = user.record.data["updated_at"]
updated_at = user["updated_at"]
loop_offset += 1
yield user

Expand Down Expand Up @@ -175,7 +175,7 @@ def read_records(self, **kwargs) -> Iterable[Mapping[str, Any]]:
for purchases in carts:
loop_offset += 1
for purchase in purchases:
updated_at = purchase.record.data["updated_at"]
updated_at = purchase["updated_at"]
yield purchase
if records_remaining_this_loop == 0:
break
Expand Down

0 comments on commit 7919fce

Please sign in to comment.