File tree Expand file tree Collapse file tree 1 file changed +3
-5
lines changed
Expand file tree Collapse file tree 1 file changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -318,13 +318,13 @@ def purge_today_partition(
318318 check = check .hasUniqueness (
319319 dq_params [snapshot_table_name ]["unique" ],
320320 lambda x : x == 1 ,
321- f' { dq_params [snapshot_table_name ][" unique" ]} are not unique' ,
321+ f" { dq_params [snapshot_table_name ][' unique' ]} are not unique" ,
322322 )
323323 if dq_params .get (snapshot_table_name , {}).get ("complete" ):
324324 check = check .hasCompleteness (
325325 dq_params [snapshot_table_name ]["complete" ],
326326 lambda x : x >= 0.99 ,
327- f' { dq_params [snapshot_table_name ][" complete" ]} has missing values' ,
327+ f" { dq_params [snapshot_table_name ][' complete' ]} has missing values" ,
328328 )
329329
330330 verificationSuite = (
@@ -335,7 +335,6 @@ def purge_today_partition(
335335 )
336336
337337 try :
338-
339338 verificationRun = verificationSuite .run ()
340339
341340 # check if any errors and raise exception if true
@@ -369,8 +368,7 @@ def purge_today_partition(
369368
370369 # if data quality tests succeed, write to S3
371370 snapshot_df = snapshot_df .repartition (200 )
372-
373-
371+
374372 resultDataFrame = DynamicFrame .fromDF (
375373 snapshot_df , glueContext , "resultDataFrame"
376374 )
You can’t perform that action at this time.
0 commit comments