Skip to content

Commit

Permalink
Fix error log bug
Browse files Browse the repository at this point in the history
  • Loading branch information
marcomarasca committed Jan 31, 2024
1 parent f5410a3 commit 509c219
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/scripts/glue_jobs/user_profile_snapshots.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ def __init__(self, mapping_list, partition_key):
def execute(self, dynamic_frame):
transformed_frame = dynamic_frame.map(f=UserProfileSnapshots.transform)
if transformed_frame.stageErrorsCount() > 0:
self.log_errors(dynamic_frame)
self.log_errors(transformed_frame)
# Filed emails is list , which we need to get first email from list if it's not empty, so drop emails field
droppedColumn_frame = transformed_frame.drop_fields(paths=[EMAILS], transformation_ctx="droppedColumn_frame")
return droppedColumn_frame
Expand Down

0 comments on commit 509c219

Please sign in to comment.